Module chain_segment 

In-process operator chain steps (fused subtask, no inter-op channels).

Each segment holds a user SourceFunction / MapFunction / … directly — no separate operator wrapper layer.

Structs

NamedStep

Enums

ChainStepKindInner

Erased chain step for heterogeneous fused chains.

Traits

ChainSegment

One step in an operator chain (same subtask, in-process).

ChainSourceSegment

Source head: pull one record; None when the source is idle or finished.

ChainTailSegment

Tail chain steps (Map / Filter / FlatMap / Sink): one record in, zero or more out. The last step is always a terminal sink (no downstream records).

Functions

filter_chain_factory

flat_map_chain_factory

instantiate_chain_steps

map_chain_factory

sink_chain_factory

source_chain_factory

Type Aliases

ChainSegmentFactory