Class ActionTransform<TInputError, TOutput>
A dataflow worker that executes an asynchronous callback once, which in turn consumes data from the upstream worker and sends data to the downstream worker. Input and error output rows have the same type, but output rows have a different type (instead use ActionTransform<TInputOutputError> if input and output rows are of the same type).
Note: Use the factory methods in ActionTransformFactory to create instances of this class.
Input data can be processed row by row via TakeRow() etc., or multiple rows can be processed via TryTakeBuffer(TInput[]) etc.
The input port uses the Default policy. Consider whether this is appropriate, or should be overridden, see BufferingMode for further details.
Also see the ActionTransform example.
Inheritance
Implements
Inherited Members
Namespace: actionETL
Assembly: actionETL.dll
Syntax
public class ActionTransform<TInputError, TOutput> : ActionWorkerBase<ActionTransform<TInputError, TOutput>>, IDisposeOnFinished where TInputError : class where TOutput : class
Type Parameters
Name | Description |
---|---|
TInputError | The type of input as well as error output rows. |
TOutput | The type of output rows. |
Properties
ErrorOutput
Gets the error output port for sending error rows to logging and an optional downstream worker.
Declaration
public ErrorOutputPort<TInputError> ErrorOutput { get; }
Property Value
Type | Description |
---|---|
ErrorOutputPort<TInputError> |
Input
Gets the input port for receiving rows from an upstream worker.
Declaration
public InputPort<TInputError> Input { get; }
Property Value
Type | Description |
---|---|
InputPort<TInputError> |
Output
Gets the output port for sending rows to the downstream worker.
Declaration
public OutputPort<TOutput> Output { get; }
Property Value
Type | Description |
---|---|
OutputPort<TOutput> |