DataFlowPipelineInputFlow
class DataFlowPipelineInputFlow(inputFlow: Flow<DestinationMessage>, stateStore: StateStore, stateKeyClient: StateKeyClient, completionTracker: StreamCompletionTracker, statsStore: EmittedStatsStore) : Flow<DataFlowStageIO>
Takes DestinationMessages and emits DataFlowStageIO.
Adds state ids to the input, handling the serial case where we infer the state id from a global counter.
Constructors
Link copied to clipboard
constructor(inputFlow: Flow<DestinationMessage>, stateStore: StateStore, stateKeyClient: StateKeyClient, completionTracker: StreamCompletionTracker, statsStore: EmittedStatsStore)