DataFlowPipeline
class DataFlowPipeline(input: Flow<DataFlowStageIO>, parse: DataFlowStage, aggregate: AggregateStage, flush: DataFlowStage, state: DataFlowStage, completionHandler: PipelineCompletionHandler, aggregatePublishingConfig: AggregatePublishingConfig, aggregationDispatcher: CoroutineDispatcher, flushDispatcher: CoroutineDispatcher)
Constructors
Link copied to clipboard
constructor(input: Flow<DataFlowStageIO>, parse: DataFlowStage, aggregate: AggregateStage, flush: DataFlowStage, state: DataFlowStage, completionHandler: PipelineCompletionHandler, aggregatePublishingConfig: AggregatePublishingConfig, aggregationDispatcher: CoroutineDispatcher, flushDispatcher: CoroutineDispatcher)