Class SplitTransform<TInputOutputError>
A dataflow worker with one input, one or more outputs, and one error output port, all of the same type, that sends each incoming row to one of several output ports, or to the error output port, or discards the row, based on a supplied function.
Note that output ports can be added after the worker is created (but before it or its siblings have started) by repeatedly calling Create<TOutput>(String). This can be particularly useful when generating workers in a loop.
Implements
Inherited Members
Namespace: actionETL
Assembly: actionETL.dll
Syntax
public class SplitTransform<TInputOutputError> : WorkerBase<SplitTransform<TInputOutputError>>, IDisposeOnFinished where TInputOutputError : classType Parameters
| Name | Description |
|---|---|
| TInputOutputError | The type of each row. |
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 consuming rows from the upstream worker.
Declaration
public InputPort<TInputOutputError> Input { get; }Property Value
| Type | Description |
|---|---|
| InputPort<TInputOutputError> |
TypedOutputs
Gets the typed output ports.
Declaration
public OutputPortCollection<TInputOutputError> TypedOutputs { get; }Property Value
| Type | Description |
|---|---|
| OutputPortCollection<TInputOutputError> |
Methods
RunAsync()
This method can be overridden to add custom functionality to the derived worker that runs before
and after the row processing. In this case, the base class base.RunAsync() must
be called for the worker to function correctly.
Typically, this worker is used without overriding this method.
Declaration
protected override async Task<OutcomeStatus> RunAsync()Returns
| Type | Description |
|---|---|
| Task<OutcomeStatus> | A |