Namespace DotnetKit.DataflowBuilder
Classes
- DataFlowPipelineBuilder
Provides factory methods for initiating fluent dataflow pipelines from single or multiple data sources.
- DataFlowPipelineBuilder<TSource>
Implements a fluent pipeline builder managing a sequence of linked IDataflowBlock instances.
- DataFlowPipelineBuilder<TSource1, TSource2>
Implements a multi-source dataflow pipeline builder joining two data streams with a JoinBlock<T1, T2>.
- DataflowPipeline<TSource>
Implements an executable single-source dataflow pipeline encapsulating an ingress target block and an egress destination block.
- DataflowPipeline<TSource1, TSource2>
Implements an executable multi-source dataflow pipeline that receives items from two distinct sources, joining them internally for downstream pipeline processing.
- PipelineBuilderExtensions
Provides fluent extension methods for configuring stages, transformations, batching, grouping, and targets on pipeline builders.
- PipelineExtensions
Provides extension methods for ingesting data streams into IPipeline<TSource> instances.
Interfaces
- IPipelineBuilder<TSource1, TSource2>
Defines a multi-source pipeline builder that joins two inputs (
TSource1andTSource2).