Class RowActionTransform<TInputOutputError>
A dataflow worker which executes a callback on each row passing through the transform.
The callback is passed the row as a parameter, to read and modify as needed before
it's automatically passed to the downstream worker. The callback does not
itself take rows from or send rows to the ports. If the callback throws an exception,
the input row will be rejected to the ErrorOutput port.
Note: Use the factory methods in RowActionTransformFactory to create instances of this class.
Use RowActionTransform<TInputError, TOutput> instead if the input and output types are different.
The input port uses the Default policy. Consider whether this is appropriate, or should be overridden, see BufferingMode for further details.
Also see the RowActionTransform example.
Note that this worker does not support asynchronous row methods. If that is needed, consider using RowsActionTransform<TInputOutputError> or RowsTransformBase<TDerived, TInput, TOutput, TError> instead.
To create a transform without any ErrorOutput, consider inheriting from
RowsTransformBase<TDerived, TInput, TOutput>.
Inheritance
Implements
Inherited Members
Namespace: actionETL
Assembly: actionETL.dll
Syntax
public class RowActionTransform<TInputOutputError> : RowTransformBase<RowActionTransform<TInputOutputError>, TInputOutputError>, IDisposeOnFinished where TInputOutputError : classType Parameters
| Name | Description |
|---|---|
| TInputOutputError | The type of each |
Methods
OnInputRow(TInputOutputError)
For internal use.
Declaration
protected override sealed TransformRowTreatment OnInputRow(TInputOutputError inputRow)Parameters
| Type | Name | Description |
|---|---|---|
| TInputOutputError | inputRow | Incoming row. |
Returns
| Type | Description |
|---|---|
| TransformRowTreatment |