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)

Functions

Link copied to clipboard
suspend fun run()