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 A align_to (SlidingWindow property), [1] (TumblingWindow property), [1] 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) branch() (in module bytewax.operators) BranchOut (class in bytewax.operators) build() (DynamicSink method) (DynamicSource method) (KafkaSink method) (StdOutSink method) (TestingSink 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._encoder module bytewax._metrics 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.window module bytewax.outputs module bytewax.recovery module bytewax.run module bytewax.serde module bytewax.testing module bytewax.tracing module BYTEWAX_CONSUMER_LAG_GAUGE (in module bytewax.connectors.kafka) BytewaxTracer (class in bytewax._bytewax) C C (in module bytewax.operators.window) cli_main() (in module bytewax._bytewax) (in module bytewax.run) ClockConfig (class in bytewax._bytewax) (class in bytewax.operators.window) close() (StatefulSinkPartition method) (StatefulSourcePartition method) (StatelessSinkPartition method) (StatelessSourcePartition method) close_time (WindowMetadata property), [1] cluster_main() (in module bytewax._bytewax) (in module bytewax.testing) collect() (in module bytewax.operators) collect_window() (in module bytewax.operators.window) count_final() (in module bytewax.operators) count_window() (in module bytewax.operators.window) CSVSource (class in bytewax.connectors.files) D Dataflow (class in bytewax.dataflow) DataflowId (class in bytewax.dataflow) db_dir (RecoveryConfig property), [1] de() (JsonPickleSerde static method) (Serde static method) 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 (UnaryLogic attribute) DK (in module bytewax.operators.window) dt_getter (EventClockConfig property), [1] DV (in module bytewax.operators.window) 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] err (KafkaError attribute) errs (KafkaOpOut attribute) EventClockConfig (class in bytewax._bytewax) (class in bytewax.operators.window) 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_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.window) from_port_ids (RenderedPort attribute) from_stream_ids (RenderedPort attribute) G gap (SessionWindow property), [1] generate_python_metrics() (in module bytewax._metrics) 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) J JaegerConfig (class in bytewax._bytewax) (class in bytewax.tracing) join() (in module bytewax.operators) join_named() (in module bytewax.operators) join_window() (in module bytewax.operators.window) join_window_named() (in module bytewax.operators.window) json_for() (in module bytewax._encoder) JsonPickleSerde (class in bytewax.serde) 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) KeyedStream (in module bytewax.operators) L latency (KafkaSourceMessage attribute) length (SlidingWindow property), [1] (TumblingWindow property), [1] 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.window) MaybeStrBytes (in module bytewax.connectors.kafka) merge() (in module bytewax.operators) min_final() (in module bytewax.operators) min_window() (in module bytewax.operators.window) module bytewax bytewax._bytewax bytewax._encoder bytewax._metrics 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.window bytewax.outputs bytewax.recovery bytewax.run bytewax.serde bytewax.testing bytewax.tracing 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() (UnaryLogic method) O offset (KafkaSourceMessage attribute) (SlidingWindow property), [1] oks (KafkaOpOut attribute) on_eof() (UnaryLogic method) on_item() (UnaryLogic method) on_notify() (UnaryLogic method) op_type (RenderedOperator attribute) open_time (WindowMetadata property), [1] 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) 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.window) RenderedDataflow (class in bytewax._encoder) RenderedOperator (class in bytewax._encoder) RenderedPort (class in bytewax._encoder) RETAIN (UnaryLogic 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] ser() (JsonPickleSerde static method) (Serde static method) Serde (class in bytewax.serde) 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] SessionWindow (class in bytewax._bytewax) (class in bytewax.operators.window) 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) SlidingWindow (class in bytewax._bytewax) (class in bytewax.operators.window) snapshot() (StatefulSinkPartition method) (StatefulSourcePartition method) (UnaryLogic method) snapshot_serde (RecoveryConfig property), [1] Source (class in bytewax.inputs) stateful_flat_map() (in module bytewax.operators) stateful_map() (in module 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) SystemClockConfig (class in bytewax._bytewax) (class in bytewax.operators.window) T test_cluster() (in module bytewax._bytewax) 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) to_json() (in module bytewax._encoder) to_plantuml() (in module bytewax._encoder) to_rendered() (in module bytewax._encoder) to_sink() (KafkaSourceMessage method) topic (KafkaSinkMessage attribute) (KafkaSourceMessage attribute) TracingConfig (class in bytewax._bytewax) (class in bytewax.tracing) trues (BranchOut attribute) TumblingWindow (class in bytewax._bytewax) (class in bytewax.operators.window) U unary() (in module bytewax.operators) UnaryLogic (class in bytewax.operators) ups_names (Operator attribute) url (OtlpTracingConfig property), [1] 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) value (KafkaSinkMessage attribute) (KafkaSourceMessage attribute) W W (in module bytewax.operators) wait_for_system_duration (EventClockConfig property), [1] WindowConfig (class in bytewax._bytewax) (class in bytewax.operators.window) WindowMetadata (class in bytewax._bytewax) (class in bytewax.operators.window) write_batch() (StatefulSinkPartition method) (StatelessSinkPartition method) X X (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)