Index A | B | C | D | E | F | G | H | I | J | K | L | M | N | O | P | R | S | T | U | V | W | X | Y | Z A advance() (TimeTestingGetter method) align_to (SlidingWindower attribute) (TumblingWindower attribute) B backup_interval (RecoveryConfig property), [1] batch() (in module bytewax.inputs) batch_async() (in module bytewax.inputs) batch_getter() (in module bytewax.inputs) batch_getter_ex() (in module bytewax.inputs) before_batch() (ClockLogic method) branch() (in module bytewax.operators) BranchOut (class in bytewax.operators) build() (Clock method) (DynamicSink method) (DynamicSource method) (EventClock method) (KafkaSink method) (SessionWindower method) (SlidingWindower method) (StdOutSink method) (SystemClock method) (TestingSink method) (TumblingWindower method) (Windower method) build_part() (CSVSource method) (DirSink method) (DirSource method) (FileSink method) (FileSource method) (FixedPartitionedSink method) (FixedPartitionedSource method) (KafkaSource method) (RandomMetricSource method) (SimplePollingSource method) (TestingSource method) bytewax module bytewax._bytewax module bytewax._metrics module bytewax._utils module bytewax.connectors module bytewax.connectors.demo module bytewax.connectors.files module bytewax.connectors.kafka module bytewax.connectors.kafka.operators module bytewax.connectors.kafka.serde module bytewax.connectors.stdio module bytewax.dataflow module bytewax.inputs module bytewax.operators module bytewax.operators.helpers module bytewax.operators.windowing module bytewax.outputs module bytewax.recovery module bytewax.run module bytewax.testing module bytewax.tracing module bytewax.visualize module BYTEWAX_CONSUMER_LAG_GAUGE (in module bytewax.connectors.kafka) BytewaxTracer (class in bytewax._bytewax) C C (in module bytewax.operators.windowing) cli_main() (in module bytewax._bytewax) (in module bytewax.run) Clock (class in bytewax.operators.windowing) ClockLogic (class in bytewax.operators.windowing) close() (StatefulSinkPartition method) (StatefulSourcePartition method) (StatelessSinkPartition method) (StatelessSourcePartition method) close_for() (WindowerLogic method) close_time (WindowMetadata attribute) cluster_main() (in module bytewax._bytewax) (in module bytewax.testing) collect() (in module bytewax.operators) collect_window() (in module bytewax.operators.windowing) count_final() (in module bytewax.operators) count_window() (in module bytewax.operators.windowing) CSVSource (class in bytewax.connectors.files) D Dataflow (class in bytewax.dataflow) DataflowId (class in bytewax.dataflow) db_dir (RecoveryConfig property), [1] deserialize() (in module bytewax.connectors.kafka.operators) deserialize_key() (in module bytewax.connectors.kafka.operators) deserialize_value() (in module bytewax.connectors.kafka.operators) DirSink (class in bytewax.connectors.files) DirSource (class in bytewax.connectors.files) DISCARD (StatefulBatchLogic attribute) (StatefulLogic attribute) DK (in module bytewax.operators) down (WindowOut attribute) DV (in module bytewax.operators) dwn_names (Operator attribute) DynamicSink (class in bytewax.outputs) DynamicSource (class in bytewax.inputs) E E (in module bytewax.connectors.kafka.operators) endpoint (JaegerConfig property), [1] enrich_cached() (in module bytewax.operators) err (KafkaError attribute) errs (KafkaOpOut attribute) EventClock (class in bytewax.operators.windowing) F F (in module bytewax.dataflow) f_repr() (in module bytewax.dataflow) falses (BranchOut attribute) ffwd_iter() (in module bytewax.testing) FileSink (class in bytewax.connectors.files) FileSource (class in bytewax.connectors.files) filter() (in module bytewax.operators) filter_map() (in module bytewax.operators) filter_map_value() (in module bytewax.operators) filter_value() (in module bytewax.operators) FixedPartitionedSink (class in bytewax.outputs) FixedPartitionedSource (class in bytewax.inputs) flat_map() (in module bytewax.operators) flat_map_batch() (in module bytewax.operators) flat_map_value() (in module bytewax.operators) flatten() (in module bytewax.operators) flow() (Stream method) flow_id (Dataflow attribute) (DataflowId attribute) (RenderedDataflow attribute) fold_final() (in module bytewax.operators) fold_window() (in module bytewax.operators.windowing) from_port_ids (RenderedPort attribute) from_stream_ids (RenderedPort attribute) G gap (SessionWindower attribute) generate_python_metrics() (in module bytewax._metrics) get() (TimeTestingGetter method) (TTLCache method) H headers (KafkaSinkMessage attribute) (KafkaSourceMessage attribute) I init_db_dir() (in module bytewax._bytewax) (in module bytewax.recovery) inp_ports (RenderedOperator attribute) input() (in module bytewax.connectors.kafka.operators) (in module bytewax.operators) inspect() (in module bytewax.operators) inspect_debug() (in module bytewax.operators) is_empty() (WindowerLogic method) J JaegerConfig (class in bytewax._bytewax) (class in bytewax.tracing) join() (in module bytewax.operators) join_window() (in module bytewax.operators.windowing) JoinMode (in module bytewax.operators) K K (in module bytewax.connectors.kafka) (in module bytewax.operators.helpers) K2 (in module bytewax.connectors.kafka) K_co (in module bytewax.connectors.kafka) KafkaError (class in bytewax.connectors.kafka) KafkaOpOut (class in bytewax.connectors.kafka.operators) KafkaSink (class in bytewax.connectors.kafka) KafkaSinkMessage (class in bytewax.connectors.kafka) KafkaSource (class in bytewax.connectors.kafka) KafkaSourceError (in module bytewax.connectors.kafka) KafkaSourceMessage (class in bytewax.connectors.kafka) key (KafkaSinkMessage attribute) (KafkaSourceMessage attribute) key_on() (in module bytewax.operators) key_rm() (in module bytewax.operators) KeyedStream (in module bytewax.operators) L late (WindowOut attribute) late_for() (WindowerLogic method) LATE_SESSION_ID (in module bytewax.operators.windowing) latency (KafkaSourceMessage attribute) length (SlidingWindower attribute) (TumblingWindower attribute) list_parts() (CSVSource method) (DirSink method) (DirSource method) (FileSink method) (FileSource method) (FixedPartitionedSink method) (FixedPartitionedSource method) (KafkaSource method) (RandomMetricSource method) (SimplePollingSource method) (TestingSource method) M map() (in module bytewax.operators) map_dict_value() (in module bytewax.operators.helpers) map_value() (in module bytewax.operators) max_final() (in module bytewax.operators) max_window() (in module bytewax.operators.windowing) merge() (in module bytewax.operators) merged() (WindowerLogic method) meta (WindowOut attribute) metadata_for() (WindowerLogic method) min_final() (in module bytewax.operators) min_window() (in module bytewax.operators.windowing) module bytewax bytewax._bytewax bytewax._metrics bytewax._utils bytewax.connectors bytewax.connectors.demo bytewax.connectors.files bytewax.connectors.kafka bytewax.connectors.kafka.operators bytewax.connectors.kafka.serde bytewax.connectors.stdio bytewax.dataflow bytewax.inputs bytewax.operators bytewax.operators.helpers bytewax.operators.windowing bytewax.outputs bytewax.recovery bytewax.run bytewax.testing bytewax.tracing bytewax.visualize msg (KafkaError attribute) MultiPort (class in bytewax.dataflow) N N (in module bytewax.dataflow) next_awake() (StatefulSourcePartition method) (StatelessSourcePartition method) next_batch() (StatefulSourcePartition method) (StatelessSourcePartition method) next_item() (SimplePollingSource method) notify_at() (StatefulBatchLogic method) (StatefulLogic method) (WindowerLogic method) now (TimeTestingGetter attribute) now_getter (EventClock attribute) (TTLCache attribute) O offset (KafkaSourceMessage attribute) (SlidingWindower attribute) oks (KafkaOpOut attribute) on_batch() (StatefulBatchLogic method) on_close() (WindowLogic method) on_eof() (ClockLogic method) (StatefulBatchLogic method) (StatefulLogic method) on_item() (ClockLogic method) (StatefulLogic method) on_merge() (WindowLogic method) on_notify() (ClockLogic method) (StatefulBatchLogic method) (StatefulLogic method) on_value() (WindowLogic method) op_type (RenderedOperator attribute) open_for() (WindowerLogic method) open_time (WindowMetadata attribute) Operator (class in bytewax.dataflow) operator() (in module bytewax.dataflow) OtlpTracingConfig (class in bytewax._bytewax) (class in bytewax.tracing) out_ports (RenderedOperator attribute) output() (in module bytewax.connectors.kafka.operators) (in module bytewax.operators) P P (in module bytewax.dataflow) part_fn() (DirSink method) (FileSink method) (FixedPartitionedSink method) partition (KafkaSinkMessage attribute) (KafkaSourceMessage attribute) partition() (in module bytewax._utils) PlainAvroDeserializer (class in bytewax.connectors.kafka.serde) PlainAvroSerializer (class in bytewax.connectors.kafka.serde) poll_next_batch() (in module bytewax.testing) Port (class in bytewax.dataflow) port_id (MultiPort attribute) (Port attribute) (RenderedPort attribute) (SinglePort attribute) port_name (RenderedPort attribute) R R (in module bytewax.dataflow) raises() (in module bytewax.operators) RandomMetricSource (class in bytewax.connectors.demo) RecoveryConfig (class in bytewax._bytewax) (class in bytewax.recovery) redistribute() (in module bytewax.operators) reduce_final() (in module bytewax.operators) reduce_window() (in module bytewax.operators.windowing) remove() (TTLCache method) RenderedDataflow (class in bytewax.visualize) RenderedOperator (class in bytewax.visualize) RenderedPort (class in bytewax.visualize) RETAIN (StatefulBatchLogic attribute) (StatefulLogic attribute) run_main() (in module bytewax._bytewax) (in module bytewax.testing) S S (in module bytewax.inputs) (in module bytewax.operators) (in module bytewax.outputs) sampling_ratio (JaegerConfig property), [1] (OtlpTracingConfig property), [1] SC (in module bytewax.operators.windowing) serialize() (in module bytewax.connectors.kafka.operators) serialize_key() (in module bytewax.connectors.kafka.operators) serialize_value() (in module bytewax.connectors.kafka.operators) SerializedKafkaSinkMessage (in module bytewax.connectors.kafka) SerializedKafkaSourceMessage (in module bytewax.connectors.kafka) SerializedKafkaSourceResult (in module bytewax.connectors.kafka) service_name (JaegerConfig property), [1] (OtlpTracingConfig property), [1] SessionWindower (class in bytewax.operators.windowing) setup_tracing() (in module bytewax._bytewax) (in module bytewax.tracing) SimplePollingSource (class in bytewax.inputs) SimplePollingSource.Retry SinglePort (class in bytewax.dataflow) Sink (class in bytewax.outputs) SlidingWindower (class in bytewax.operators.windowing) snapshot() (ClockLogic method) (StatefulBatchLogic method) (StatefulLogic method) (StatefulSinkPartition method) (StatefulSourcePartition method) (WindowerLogic method) (WindowLogic method) Source (class in bytewax.inputs) stateful() (in module bytewax.operators) stateful_batch() (in module bytewax.operators) stateful_flat_map() (in module bytewax.operators) stateful_map() (in module bytewax.operators) StatefulBatchLogic (class in bytewax.operators) StatefulLogic (class in bytewax.operators) StatefulSinkPartition (class in bytewax.outputs) StatefulSourcePartition (class in bytewax.inputs) StatelessSinkPartition (class in bytewax.outputs) StatelessSourcePartition (class in bytewax.inputs) StdOutSink (class in bytewax.connectors.stdio) step_id (Operator attribute) (RenderedOperator attribute) step_name (Operator attribute) (RenderedOperator attribute) Stream (class in bytewax.dataflow) stream_id (SinglePort attribute) (Stream attribute) stream_ids (MultiPort attribute) (Port attribute) (SinglePort property) substeps (Dataflow attribute) (Operator attribute) (RenderedDataflow attribute) (RenderedOperator attribute) SW (in module bytewax.operators.windowing) SystemClock (class in bytewax.operators.windowing) T TestingSink (class in bytewax.testing) TestingSource (class in bytewax.testing) TestingSource.ABORT (class in bytewax.testing) TestingSource.EOF (class in bytewax.testing) then() (Stream method) timeout (SimplePollingSource.Retry attribute) timestamp (KafkaSinkMessage attribute) (KafkaSourceMessage attribute) TimeTestingGetter (class in bytewax.testing) to_json() (in module bytewax.visualize) to_mermaid() (in module bytewax.visualize) to_plantuml() (in module bytewax.visualize) to_rendered() (in module bytewax.visualize) to_sink() (KafkaSourceMessage method) to_system_utc (EventClock attribute) to_system_utc() (ClockLogic method) topic (KafkaSinkMessage attribute) (KafkaSourceMessage attribute) TracingConfig (class in bytewax._bytewax) (class in bytewax.tracing) trues (BranchOut attribute) ts_getter (EventClock attribute) ttl (TTLCache attribute) TTLCache (class in bytewax.operators) TumblingWindower (class in bytewax.operators.windowing) U U (in module bytewax.operators) ups_names (Operator attribute) url (OtlpTracingConfig property), [1] UTC_MAX (in module bytewax.operators.windowing) UTC_MIN (in module bytewax.operators.windowing) V V (in module bytewax.connectors.kafka) (in module bytewax.operators) (in module bytewax.operators.helpers) V2 (in module bytewax.connectors.kafka) V_co (in module bytewax.connectors.kafka) v_getter (TTLCache attribute) value (KafkaSinkMessage attribute) (KafkaSourceMessage attribute) W W (in module bytewax.operators) W_co (in module bytewax.operators) wait_for_system_duration (EventClock attribute) window() (in module bytewax.operators.windowing) Windower (class in bytewax.operators.windowing) WindowerLogic (class in bytewax.operators.windowing) WindowLogic (class in bytewax.operators.windowing) WindowMetadata (class in bytewax.operators.windowing) WindowOut (class in bytewax.operators.windowing) write_batch() (StatefulSinkPartition method) (StatelessSinkPartition method) X X (in module bytewax._utils) (in module bytewax.connectors.demo) (in module bytewax.connectors.kafka.operators) (in module bytewax.inputs) (in module bytewax.operators) (in module bytewax.outputs) X_co (in module bytewax.dataflow) Y Y (in module bytewax.operators) Z ZERO_TD (in module bytewax.operators.windowing)