Class ActionTransform<TInputOutputError>
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, output, and error output rows have the same type (instead use ActionTransform<TInputError, TOutput> if input and output rows have different types).
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<TInputOutputError> : ActionWorkerBase<ActionTransform<TInputOutputError>>, IDisposeOnFinished where TInputOutputError : classType Parameters
| Name | Description |
|---|---|
| TInputOutputError | The type of each |
Properties
ErrorOutput
Gets the error output port for sending error rows to logging and an optional downstream worker.
Declaration
public ErrorOutputPort<TInputOutputError> ErrorOutput { get; }Property Value
| Type | Description |
|---|---|
| ErrorOutputPort<TInputOutputError> |
Input
Gets the input port for receiving rows from an upstream worker.
Declaration
public InputPort<TInputOutputError> Input { get; }Property Value
| Type | Description |
|---|---|
| InputPort<TInputOutputError> |
Output
Gets the output port for sending rows to the downstream worker.
Declaration
public OutputPort<TInputOutputError> Output { get; }Property Value
| Type | Description |
|---|---|
| OutputPort<TInputOutputError> |