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
Object
WorkerParent
WorkerBase
WorkerBase<ActionTransform<TInputError, TOutput>>
ActionWorkerBase<ActionTransform<TInputError, TOutput>>
ActionTransform<TInputError, TOutput>
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>

Implements

See Also

ActionTransform<TInputOutputError>