Compose sets the sink of op1 and the source of op2.

NewAsyncOperator create an AsyncOperator.

NewAsyncOperatorWithTransform create an AsyncOperator with a transform function.

NewAsyncPipeline creates a new AsyncPipeline.

NewSimpleDataChannel creates a new SimpleDataChannel.

AsyncOperator process the data in async way.

AsyncPipeline wraps a list of Operators.

SimpleDataChannel is a simple implementation of DataChannel.

DataChannel is a channel that can be used to transfer data between operators.

Operator is the basic operation unit in the task execution.

WithSink is an interface that can be used to set the sink of an operator.

WithSource is an interface that can be used to set the source of an operator.