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