Search Results for

    Show / Hide Table of Contents

    Struct DownstreamFactory<TOutput>

    A factory that creates dataflow transforms or targets, and links their "first" input port to (if available) the output or error output port specified by the factory. See Worker Instantiation and Transform and Target Factory Methods for details.

    Get the factory from Link when the upstream port is known ahead of time (which is usually the case). Otherwise get it from GetDownstreamFactory<TInput>(), and link the transform or target explicitly using LinkTo(InputPort<TOutput>) or LinkFrom(OutputPortBase<TInput>).

    Note that each factory is immutable, and also does not contain any methods for creating workers. Instead, the developer of a new transform or target worker creates extension methods (targeting this struct), which create and link the new worker.

    Implements
    IFluentInterface
    IEquatable<DownstreamFactory<TOutput>>
    Inherited Members
    ValueType.ToString()
    Namespace: actionETL
    Assembly: actionETL.dll
    Syntax
    public readonly struct DownstreamFactory<TOutput> : IFluentInterface, IEquatable<DownstreamFactory<TOutput>> where TOutput : class
    Type Parameters
    Name Description
    TOutput

    The type of the rows for the "first" input of the transform or target to create.

    Properties

    UpstreamPort

    Gets the upstream port that the transform or target "first" input port should be linked to.

    Can be null, in which case the newly created transform or target must be linked (using LinkTo(InputPort<TOutput>) or LinkFrom(OutputPortBase<TInput>)) to an upstream worker before it and its siblings are run.

    Declaration
    public readonly OutputPortBase<TOutput> UpstreamPort { get; }
    Property Value
    Type Description
    OutputPortBase<TOutput>

    WorkerParent

    Gets the worker that the transform or target should be added to, i.e. have as a parent.

    Declaration
    public readonly WorkerParent WorkerParent { get; }
    Property Value
    Type Description
    WorkerParent

    Methods

    Equals(DownstreamFactory<TOutput>)

    Indicates whether the current object is equal to another object of the same type.

    Declaration
    public readonly bool Equals(DownstreamFactory<TOutput> other)
    Parameters
    Type Name Description
    DownstreamFactory<TOutput> other

    An object to compare with this object.

    Returns
    Type Description
    Boolean

    true if the current object is equal to the other parameter; otherwise, false.

    Equals(Object)

    Determines whether the specified Object is equal to this instance.

    Declaration
    public override readonly bool Equals(object obj)
    Parameters
    Type Name Description
    Object obj

    The Object to compare with this instance.

    Returns
    Type Description
    Boolean

    true if the specified Object is equal to this instance; otherwise, false.

    Overrides
    ValueType.Equals(Object)

    GetHashCode()

    Returns a hash code for this instance.

    Declaration
    public override readonly int GetHashCode()
    Returns
    Type Description
    Int32

    A hash code for this instance, suitable for use in hashing algorithms and data structures like a hash table.

    Overrides
    ValueType.GetHashCode()

    Operators

    Equality(DownstreamFactory<TOutput>, DownstreamFactory<TOutput>)

    Implements the operator ==.

    Declaration
    public static bool operator ==(DownstreamFactory<TOutput> left, DownstreamFactory<TOutput> right)
    Parameters
    Type Name Description
    DownstreamFactory<TOutput> left

    The left.

    DownstreamFactory<TOutput> right

    The right.

    Returns
    Type Description
    Boolean

    The result of the operator.

    Inequality(DownstreamFactory<TOutput>, DownstreamFactory<TOutput>)

    Implements the operator !=.

    Declaration
    public static bool operator !=(DownstreamFactory<TOutput> left, DownstreamFactory<TOutput> right)
    Parameters
    Type Name Description
    DownstreamFactory<TOutput> left

    The left.

    DownstreamFactory<TOutput> right

    The right.

    Returns
    Type Description
    Boolean

    The result of the operator.

    Implements

    IFluentInterface
    System.IEquatable<T>

    Extension Methods

    ActionTargetFactory.ActionTarget<TInput>(in DownstreamFactory<TInput>, String, Func<ActionTarget<TInput>, Task>)
    ActionTargetFactory.ActionTarget<TInput>(in DownstreamFactory<TInput>, String, Func<ActionTarget<TInput>, Task<OutcomeStatus>>)
    ActionTargetFactory.ActionTarget<TInput, TError>(in DownstreamFactory<TInput>, String, Func<ActionTarget<TInput, TError>, Task>)
    ActionTargetFactory.ActionTarget<TInput, TError>(in DownstreamFactory<TInput>, String, Func<ActionTarget<TInput, TError>, Task<OutcomeStatus>>)
    CollectionTargetFactory.CollectionTarget<TInput, TCollection>(in DownstreamFactory<TInput>, String, TCollection)
    CollectionTargetFactory.CollectionTarget<TInput, TCollection>(in DownstreamFactory<TInput>, TCollection)
    CollectionTargetFactory.CollectionTarget<TInput>(in DownstreamFactory<TInput>, String)
    CollectionTargetFactory.CollectionTarget<TInput>(in DownstreamFactory<TInput>)
    DictionaryTargetFactory.DictionaryTarget<TInput, TKey, TValue>(in DownstreamFactory<TInput>, String, IDictionary<TKey, TValue>, Func<TInput, KeyValuePair<TKey, TValue>>, DictionaryAddKeyTreatment)
    DictionaryTargetFactory.DictionaryTarget<TInput, TKey, TValue>(in DownstreamFactory<TInput>, String, IDictionary<TKey, TValue>, Func<TInput, KeyValuePair<TKey, TValue>>)
    DictionaryTargetFactory.DictionaryTarget<TInput, TKey, TValue>(in DownstreamFactory<TInput>, String, Func<TInput, KeyValuePair<TKey, TValue>>)
    PortPassThroughTargetFactory.PortPassThroughTarget<TInputOutput>(in DownstreamFactory<TInputOutput>, String, OutputPort<TInputOutput>)
    RowActionTargetFactory.RowActionTarget<TInput>(in DownstreamFactory<TInput>, String, Func<RowActionTarget<TInput>, Task<ProgressStatus>>, Action<TInput>, Func<RowActionTarget<TInput>, OutcomeStatus, WorkerParentChildrenState, Task<OutcomeStatus>>)
    RowActionTargetFactory.RowActionTarget<TInput>(in DownstreamFactory<TInput>, String, Action<TInput>)
    RowActionTargetFactory.RowActionTarget<TInput>(in DownstreamFactory<TInput>, String, Func<RowActionTarget<TInput>, Task<ProgressStatus>>, Func<TInput, ProgressStatus>, Func<RowActionTarget<TInput>, OutcomeStatus, WorkerParentChildrenState, Task<OutcomeStatus>>)
    RowActionTargetFactory.RowActionTarget<TInput>(in DownstreamFactory<TInput>, String, Func<TInput, ProgressStatus>)
    RowsActionTargetFactory.RowsActionTarget<TInput>(in DownstreamFactory<TInput>, String, Action<RowsActionTarget<TInput>>)
    RowsActionTargetFactory.RowsActionTarget<TInput>(in DownstreamFactory<TInput>, String, Func<RowsActionTarget<TInput>, Task<ProgressStatus>>, Func<RowsActionTarget<TInput>, ProgressStatus>, Func<RowsActionTarget<TInput>, OutcomeStatus, WorkerParentChildrenState, Task<OutcomeStatus>>)
    RowsActionTargetFactory.RowsActionTarget<TInput>(in DownstreamFactory<TInput>, String, Func<RowsActionTarget<TInput>, ProgressStatus>)
    RowsActionTargetFactory.RowsActionTarget<TInput>(in DownstreamFactory<TInput>, String, Func<RowsActionTarget<TInput>, Task>)
    RowsActionTargetFactory.RowsActionTarget<TInput>(in DownstreamFactory<TInput>, String, Func<RowsActionTarget<TInput>, Task<ProgressStatus>>, Func<RowsActionTarget<TInput>, Task<ProgressStatus>>, Func<RowsActionTarget<TInput>, OutcomeStatus, WorkerParentChildrenState, Task<OutcomeStatus>>)
    RowsActionTargetFactory.RowsActionTarget<TInput>(in DownstreamFactory<TInput>, String, Func<RowsActionTarget<TInput>, Task<ProgressStatus>>)
    TrashTargetFactory.TrashTarget<TInput>(in DownstreamFactory<TInput>, String)
    TrashTargetFactory.TrashTarget<TInput>(in DownstreamFactory<TInput>)
    ActionTransformFactory.ActionTransform1<TInputOutputError>(in DownstreamFactory<TInputOutputError>, String, Func<ActionTransform<TInputOutputError>, Task>)
    ActionTransformFactory.ActionTransform1<TInputOutputError>(in DownstreamFactory<TInputOutputError>, String, Func<ActionTransform<TInputOutputError>, Task<OutcomeStatus>>)
    ActionTransformFactory.ActionTransform2<TInputError, TOutput>(in DownstreamFactory<TInputError>, String, Func<ActionTransform<TInputError, TOutput>, Task>)
    ActionTransformFactory.ActionTransform2<TInputError, TOutput>(in DownstreamFactory<TInputError>, String, Func<ActionTransform<TInputError, TOutput>, Task<OutcomeStatus>>)
    ActionTwoInputTransformFactory.ActionTwoInputTransform<TLeftInput, TRightInput, TOutput>(in DownstreamFactory<TLeftInput>, String, OutputPortBase<TRightInput>, Func<ActionTwoInputTransform<TLeftInput, TRightInput, TOutput>, Task>)
    ActionTwoInputTransformFactory.ActionTwoInputTransform<TLeftInput, TRightInput, TOutput>(in DownstreamFactory<TLeftInput>, String, OutputPortBase<TRightInput>, Func<ActionTwoInputTransform<TLeftInput, TRightInput, TOutput>, Task<OutcomeStatus>>)
    AggregateTransformFactory.AggregateTransform1<TInputAccumulateOutput>(in DownstreamFactory<TInputAccumulateOutput>, String, Action<TransformAggregation<TInputAccumulateOutput>>, Action<TransformAggregation<TInputAccumulateOutput>>, Func<TransformAggregation<TInputAccumulateOutput>, TInputAccumulateOutput>, IEqualityComparer<TInputAccumulateOutput>)
    AggregateTransformFactory.AggregateTransform1<TInputAccumulateOutput>(in DownstreamFactory<TInputAccumulateOutput>, String, RowAggregationFunction, IEqualityComparer<TInputAccumulateOutput>)
    AggregateTransformFactory.AggregateTransform1<TInputAccumulateOutput>(in DownstreamFactory<TInputAccumulateOutput>, String, RowAggregationFunction, Action<IGroupByCommand>)
    AggregateTransformFactory.AggregateTransform1<TInputAccumulateOutput>(in DownstreamFactory<TInputAccumulateOutput>, String, RowAggregationFunction)
    AggregateTransformFactory.AggregateTransform2<TInput, TAccumulateOutput>(in DownstreamFactory<TInput>, String, Action<TransformAggregation<TInput, TAccumulateOutput>>, Action<TransformAggregation<TInput, TAccumulateOutput>>, Func<TransformAggregation<TInput, TAccumulateOutput>, TAccumulateOutput>, IEqualityComparer<TInput>)
    AggregateTransformFactory.AggregateTransform2<TInput, TOutput>(in DownstreamFactory<TInput>, String, Action<IAggregationCommand>, Action<IGroupByCopyCommand>)
    AggregateTransformFactory.AggregateTransform2<TInput, TOutput>(in DownstreamFactory<TInput>, String, Action<IAggregationCommand>)
    AggregateTransformFactory.AggregateTransform3<TInput, TAccumulate, TOutput>(in DownstreamFactory<TInput>, String, Action<TransformAggregation<TInput, TAccumulate>>, Action<TransformAggregation<TInput, TAccumulate>>, Func<TransformAggregation<TInput, TAccumulate>, TOutput>, IEqualityComparer<TInput>)
    CrossJoinTransformFactory.CrossJoinTransform<TLeftInput, TRightInput, TOutput>(in DownstreamFactory<TLeftInput>, String, OutputPortBase<TRightInput>, Func<TLeftInput, TRightInput, TOutput>)
    CrossJoinTransformFactory.CrossJoinTransform<TLeftInput, TRightInput, TOutput>(in DownstreamFactory<TLeftInput>, String, OutputPortBase<TRightInput>, Action<IRowMapperCommand>, Action<IRowMapperCommand>)
    FullJoinMergeSortedTransformFactory.FullJoinMergeSortedTransform<TLeftInput, TRightInput, TOutput>(in DownstreamFactory<TLeftInput>, String, OutputPortBase<TRightInput>, Comparison<TLeftInput, TRightInput>, Func<TLeftInput, TRightInput, TOutput>)
    FullJoinMergeSortedTransformFactory.FullJoinMergeSortedTransform<TLeftInput, TRightInput, TOutput>(in DownstreamFactory<TLeftInput>, String, OutputPortBase<TRightInput>, Comparison<TLeftInput, TRightInput>, Action<IRowMapperCommand>, Action<IRowMapperCommand>)
    FullJoinMergeSortedTransformFactory.FullJoinMergeSortedTransform<TLeftInput, TRightInput, TOutput>(in DownstreamFactory<TLeftInput>, String, OutputPortBase<TRightInput>, Action<IRowComparerCommand<TLeftInput, TRightInput>>, Func<TLeftInput, TRightInput, TOutput>)
    FullJoinMergeSortedTransformFactory.FullJoinMergeSortedTransform<TLeftInput, TRightInput, TOutput>(in DownstreamFactory<TLeftInput>, String, OutputPortBase<TRightInput>, Action<IRowComparerCommand<TLeftInput, TRightInput>>, Action<IRowMapperCommand>, Action<IRowMapperCommand>)
    InnerJoinMergeSortedTransformFactory.InnerJoinMergeSortedTransform<TLeftInput, TRightInput, TOutput>(in DownstreamFactory<TLeftInput>, String, OutputPortBase<TRightInput>, Comparison<TLeftInput, TRightInput>, Func<TLeftInput, TRightInput, TOutput>)
    InnerJoinMergeSortedTransformFactory.InnerJoinMergeSortedTransform<TLeftInput, TRightInput, TOutput>(in DownstreamFactory<TLeftInput>, String, OutputPortBase<TRightInput>, Comparison<TLeftInput, TRightInput>, Action<IRowMapperCommand>, Action<IRowMapperCommand>)
    InnerJoinMergeSortedTransformFactory.InnerJoinMergeSortedTransform<TLeftInput, TRightInput, TOutput>(in DownstreamFactory<TLeftInput>, String, OutputPortBase<TRightInput>, Action<IRowComparerCommand<TLeftInput, TRightInput>>, Func<TLeftInput, TRightInput, TOutput>)
    InnerJoinMergeSortedTransformFactory.InnerJoinMergeSortedTransform<TLeftInput, TRightInput, TOutput>(in DownstreamFactory<TLeftInput>, String, OutputPortBase<TRightInput>, Action<IRowComparerCommand<TLeftInput, TRightInput>>, Action<IRowMapperCommand>, Action<IRowMapperCommand>)
    LeftJoinMergeSortedTransformFactory.LeftJoinMergeSortedTransform<TLeftInput, TRightInput, TOutput>(in DownstreamFactory<TLeftInput>, String, OutputPortBase<TRightInput>, Comparison<TLeftInput, TRightInput>, Func<TLeftInput, TRightInput, TOutput>)
    LeftJoinMergeSortedTransformFactory.LeftJoinMergeSortedTransform<TLeftInput, TRightInput, TOutput>(in DownstreamFactory<TLeftInput>, String, OutputPortBase<TRightInput>, Comparison<TLeftInput, TRightInput>, Action<IRowMapperCommand>, Action<IRowMapperCommand>)
    LeftJoinMergeSortedTransformFactory.LeftJoinMergeSortedTransform<TLeftInput, TRightInput, TOutput>(in DownstreamFactory<TLeftInput>, String, OutputPortBase<TRightInput>, Action<IRowComparerCommand<TLeftInput, TRightInput>>, Func<TLeftInput, TRightInput, TOutput>)
    LeftJoinMergeSortedTransformFactory.LeftJoinMergeSortedTransform<TLeftInput, TRightInput, TOutput>(in DownstreamFactory<TLeftInput>, String, OutputPortBase<TRightInput>, Action<IRowComparerCommand<TLeftInput, TRightInput>>, Action<IRowMapperCommand>, Action<IRowMapperCommand>)
    RightJoinMergeSortedTransformFactory.RightJoinMergeSortedTransform<TLeftInput, TRightInput, TOutput>(in DownstreamFactory<TLeftInput>, String, OutputPortBase<TRightInput>, Comparison<TLeftInput, TRightInput>, Func<TLeftInput, TRightInput, TOutput>)
    RightJoinMergeSortedTransformFactory.RightJoinMergeSortedTransform<TLeftInput, TRightInput, TOutput>(in DownstreamFactory<TLeftInput>, String, OutputPortBase<TRightInput>, Comparison<TLeftInput, TRightInput>, Action<IRowMapperCommand>, Action<IRowMapperCommand>)
    RightJoinMergeSortedTransformFactory.RightJoinMergeSortedTransform<TLeftInput, TRightInput, TOutput>(in DownstreamFactory<TLeftInput>, String, OutputPortBase<TRightInput>, Action<IRowComparerCommand<TLeftInput, TRightInput>>, Func<TLeftInput, TRightInput, TOutput>)
    RightJoinMergeSortedTransformFactory.RightJoinMergeSortedTransform<TLeftInput, TRightInput, TOutput>(in DownstreamFactory<TLeftInput>, String, OutputPortBase<TRightInput>, Action<IRowComparerCommand<TLeftInput, TRightInput>>, Action<IRowMapperCommand>, Action<IRowMapperCommand>)
    DictionaryLookupSplitTransformFactory.DictionaryLookupSplitTransform<TInputOutputError, TKey, TValue>(in DownstreamFactory<TInputOutputError>, String, IReadOnlyDictionary<TKey, TValue>, Func<TInputOutputError, TKey>, Func<TInputOutputError, TKey, TValue, DictionaryLookupRowTreatment>, Func<TInputOutputError, TKey, DictionaryLookupRowTreatment>)
    DictionaryLookupSplitTransformFactory.DictionaryLookupSplitTransform<TInputOutputError, TKey, TValue>(in DownstreamFactory<TInputOutputError>, String, IReadOnlyDictionary<TKey, TValue>, Func<TInputOutputError, TKey>, Action<TInputOutputError, TKey, TValue>, Func<TInputOutputError, TKey, DictionaryLookupRowTreatment>)
    DictionaryLookupSplitTransformFactory.DictionaryLookupSplitTransform<TInputOutputError, TKey, TValue>(in DownstreamFactory<TInputOutputError>, String, IReadOnlyDictionary<TKey, TValue>, Func<TInputOutputError, TKey>, Action<TInputOutputError, TKey, TValue>)
    DictionaryLookupSplitTransformFactory.DictionaryLookupSplitTransform<TInputOutputError, TDictionaryInput, TKey, TValue>(in DownstreamFactory<TInputOutputError>, String, OutputPortBase<TDictionaryInput>, Func<TDictionaryInput, KeyValuePair<TKey, TValue>>, Func<TInputOutputError, TKey>, Func<TInputOutputError, TKey, TValue, DictionaryLookupRowTreatment>, Func<TInputOutputError, TKey, DictionaryLookupRowTreatment>)
    DictionaryLookupSplitTransformFactory.DictionaryLookupSplitTransform<TInputOutputError, TDictionaryInput, TKey, TValue>(in DownstreamFactory<TInputOutputError>, String, OutputPortBase<TDictionaryInput>, Func<TDictionaryInput, KeyValuePair<TKey, TValue>>, Func<TInputOutputError, TKey>, Action<TInputOutputError, TKey, TValue>, Func<TInputOutputError, TKey, DictionaryLookupRowTreatment>)
    DictionaryLookupSplitTransformFactory.DictionaryLookupSplitTransform<TInputOutputError, TDictionaryInput, TKey, TValue>(in DownstreamFactory<TInputOutputError>, String, OutputPortBase<TDictionaryInput>, Func<TDictionaryInput, KeyValuePair<TKey, TValue>>, Func<TInputOutputError, TKey>, Action<TInputOutputError, TKey, TValue>)
    DictionaryLookupTransformFactory.DictionaryLookupTransform<TInputOutputError, TKey, TValue>(in DownstreamFactory<TInputOutputError>, String, IReadOnlyDictionary<TKey, TValue>, Func<TInputOutputError, TKey>, Func<TInputOutputError, TKey, TValue, DictionaryLookupRowTreatment>, Func<TInputOutputError, TKey, DictionaryLookupRowTreatment>)
    DictionaryLookupTransformFactory.DictionaryLookupTransform<TInputOutputError, TKey, TValue>(in DownstreamFactory<TInputOutputError>, String, IReadOnlyDictionary<TKey, TValue>, Func<TInputOutputError, TKey>, Action<TInputOutputError, TKey, TValue>, Func<TInputOutputError, TKey, DictionaryLookupRowTreatment>)
    DictionaryLookupTransformFactory.DictionaryLookupTransform<TInputOutputError, TKey, TValue>(in DownstreamFactory<TInputOutputError>, String, IReadOnlyDictionary<TKey, TValue>, Func<TInputOutputError, TKey>, Action<TInputOutputError, TKey, TValue>)
    DictionaryLookupTransformFactory.DictionaryLookupTransform<TInputOutputError, TDictionaryInput, TKey, TValue>(in DownstreamFactory<TInputOutputError>, String, OutputPortBase<TDictionaryInput>, Func<TDictionaryInput, KeyValuePair<TKey, TValue>>, Func<TInputOutputError, TKey>, Func<TInputOutputError, TKey, TValue, DictionaryLookupRowTreatment>, Func<TInputOutputError, TKey, DictionaryLookupRowTreatment>)
    DictionaryLookupTransformFactory.DictionaryLookupTransform<TInputOutputError, TDictionaryInput, TKey, TValue>(in DownstreamFactory<TInputOutputError>, String, OutputPortBase<TDictionaryInput>, Func<TDictionaryInput, KeyValuePair<TKey, TValue>>, Func<TInputOutputError, TKey>, Action<TInputOutputError, TKey, TValue>, Func<TInputOutputError, TKey, DictionaryLookupRowTreatment>)
    DictionaryLookupTransformFactory.DictionaryLookupTransform<TInputOutputError, TDictionaryInput, TKey, TValue>(in DownstreamFactory<TInputOutputError>, String, OutputPortBase<TDictionaryInput>, Func<TDictionaryInput, KeyValuePair<TKey, TValue>>, Func<TInputOutputError, TKey>, Action<TInputOutputError, TKey, TValue>)
    MergeSortedTransformFactory.MergeSortedTransform<TInputOutput>(in DownstreamFactory<TInputOutput>, String, IComparer<TInputOutput>, OutputPortBase<TInputOutput>[])
    MergeSortedTransformFactory.MergeSortedTransform<TInputOutput>(in DownstreamFactory<TInputOutput>, String, Comparison<TInputOutput>, OutputPortBase<TInputOutput>[])
    MergeSortedTransformFactory.MergeSortedTransform<TInputOutput>(in DownstreamFactory<TInputOutput>, String, Action<IRowComparerCommand<TInputOutput>>, OutputPortBase<TInputOutput>[])
    MergeSortedTransformFactory.MergeSortedTransform<TInputOutput>(in DownstreamFactory<TInputOutput>, String, OutputPortBase<TInputOutput>[])
    MulticastTransformFactory.MulticastTransform<TInputOutput>(in DownstreamFactory<TInputOutput>, String, Func<TInputOutput, TInputOutput>, Int32)
    MulticastTransformFactory.MulticastTransform<TInputOutput>(in DownstreamFactory<TInputOutput>, String, Int32)
    MulticastTransformFactory.MulticastTransform<TInputOutput>(in DownstreamFactory<TInputOutput>, String, Func<TInputOutput, TInputOutput>, String[])
    MulticastTransformFactory.MulticastTransform<TInputOutput>(in DownstreamFactory<TInputOutput>, String, String[])
    RowActionTransformFactory.RowActionTransform1<TInputOutputError>(in DownstreamFactory<TInputOutputError>, String, Func<RowActionTransform<TInputOutputError>, Task<ProgressStatus>>, Action<TInputOutputError>, Func<RowActionTransform<TInputOutputError>, OutcomeStatus, WorkerParentChildrenState, Task<OutcomeStatus>>)
    RowActionTransformFactory.RowActionTransform1<TInputOutputError>(in DownstreamFactory<TInputOutputError>, String, Action<TInputOutputError>)
    RowActionTransformFactory.RowActionTransform1<TInputOutputError>(in DownstreamFactory<TInputOutputError>, String, Func<RowActionTransform<TInputOutputError>, Task<ProgressStatus>>, Func<TInputOutputError, TransformRowTreatment>, Func<RowActionTransform<TInputOutputError>, OutcomeStatus, WorkerParentChildrenState, Task<OutcomeStatus>>)
    RowActionTransformFactory.RowActionTransform1<TInputOutputError>(in DownstreamFactory<TInputOutputError>, String, Func<TInputOutputError, TransformRowTreatment>)
    RowActionTransformFactory.RowActionTransform2<TInputError, TOutput>(in DownstreamFactory<TInputError>, String, Func<RowActionTransform<TInputError, TOutput>, Task<ProgressStatus>>, Func<TInputError, TOutput>, Func<RowActionTransform<TInputError, TOutput>, OutcomeStatus, WorkerParentChildrenState, Task<OutcomeStatus>>)
    RowActionTransformFactory.RowActionTransform2<TInputError, TOutput>(in DownstreamFactory<TInputError>, String, Func<TInputError, TOutput>)
    RowActionTransformFactory.RowActionTransform2<TInputError, TOutput>(in DownstreamFactory<TInputError>, String, Func<RowActionTransform<TInputError, TOutput>, Task<ProgressStatus>>, Func<TInputError, (TransformRowTreatment, TOutput)>, Func<RowActionTransform<TInputError, TOutput>, OutcomeStatus, WorkerParentChildrenState, Task<OutcomeStatus>>)
    RowActionTransformFactory.RowActionTransform2<TInputError, TOutput>(in DownstreamFactory<TInputError>, String, Func<TInputError, (TransformRowTreatment, TOutput)>)
    RowsActionTransformFactory.RowsActionTransform1<TInputOutputError>(in DownstreamFactory<TInputOutputError>, String, Action<RowsActionTransform<TInputOutputError>>)
    RowsActionTransformFactory.RowsActionTransform1<TInputOutputError>(in DownstreamFactory<TInputOutputError>, String, Func<RowsActionTransform<TInputOutputError>, Task<ProgressStatus>>, Func<RowsActionTransform<TInputOutputError>, ProgressStatus>, Func<RowsActionTransform<TInputOutputError>, OutcomeStatus, WorkerParentChildrenState, Task<OutcomeStatus>>)
    RowsActionTransformFactory.RowsActionTransform1<TInputOutputError>(in DownstreamFactory<TInputOutputError>, String, Func<RowsActionTransform<TInputOutputError>, ProgressStatus>)
    RowsActionTransformFactory.RowsActionTransform1<TInputOutputError>(in DownstreamFactory<TInputOutputError>, String, Func<RowsActionTransform<TInputOutputError>, Task>)
    RowsActionTransformFactory.RowsActionTransform1<TInputOutputError>(in DownstreamFactory<TInputOutputError>, String, Func<RowsActionTransform<TInputOutputError>, Task<ProgressStatus>>, Func<RowsActionTransform<TInputOutputError>, Task<ProgressStatus>>, Func<RowsActionTransform<TInputOutputError>, OutcomeStatus, WorkerParentChildrenState, Task<OutcomeStatus>>)
    RowsActionTransformFactory.RowsActionTransform1<TInputOutputError>(in DownstreamFactory<TInputOutputError>, String, Func<RowsActionTransform<TInputOutputError>, Task<ProgressStatus>>)
    RowsActionTransformFactory.RowsActionTransform2<TInputError, TOutput>(in DownstreamFactory<TInputError>, String, Action<RowsActionTransform<TInputError, TOutput>>)
    RowsActionTransformFactory.RowsActionTransform2<TInputError, TOutput>(in DownstreamFactory<TInputError>, String, Func<RowsActionTransform<TInputError, TOutput>, Task<ProgressStatus>>, Func<RowsActionTransform<TInputError, TOutput>, ProgressStatus>, Func<RowsActionTransform<TInputError, TOutput>, OutcomeStatus, WorkerParentChildrenState, Task<OutcomeStatus>>)
    RowsActionTransformFactory.RowsActionTransform2<TInputError, TOutput>(in DownstreamFactory<TInputError>, String, Func<RowsActionTransform<TInputError, TOutput>, ProgressStatus>)
    RowsActionTransformFactory.RowsActionTransform2<TInputError, TOutput>(in DownstreamFactory<TInputError>, String, Func<RowsActionTransform<TInputError, TOutput>, Task>)
    RowsActionTransformFactory.RowsActionTransform2<TInputError, TOutput>(in DownstreamFactory<TInputError>, String, Func<RowsActionTransform<TInputError, TOutput>, Task<ProgressStatus>>, Func<RowsActionTransform<TInputError, TOutput>, Task<ProgressStatus>>, Func<RowsActionTransform<TInputError, TOutput>, OutcomeStatus, WorkerParentChildrenState, Task<OutcomeStatus>>)
    RowsActionTransformFactory.RowsActionTransform2<TInputError, TOutput>(in DownstreamFactory<TInputError>, String, Func<RowsActionTransform<TInputError, TOutput>, Task<ProgressStatus>>)
    SortTransformFactory.SortTransform<TInputOutput>(in DownstreamFactory<TInputOutput>, String, IComparer<TInputOutput>)
    SortTransformFactory.SortTransform<TInputOutput>(in DownstreamFactory<TInputOutput>, String, Comparison<TInputOutput>)
    SortTransformFactory.SortTransform<TInputOutput>(in DownstreamFactory<TInputOutput>, String)
    SortTransformFactory.SortTransform<TInputOutput>(in DownstreamFactory<TInputOutput>, String, Action<IRowComparerCommand<TInputOutput>>)
    SplitTransformFactory.SplitTransform<TInputOutputError>(in DownstreamFactory<TInputOutputError>, String, Func<TInputOutputError, Int32>, Int32)
    SplitTransformFactory.SplitTransform<TInputOutputError>(in DownstreamFactory<TInputOutputError>, String, Func<TInputOutputError, Int32>, String[])
    UnionAllTransformFactory.UnionAllTransform<TInputOutput>(in DownstreamFactory<TInputOutput>, String, OutputPortBase<TInputOutput>[])
    AdbExecuteNonQueryTargetFactory.AdbExecuteNonQueryTarget<TInputError>(in DownstreamFactory<TInputError>, String, AdbCommandBuilder)
    AdbInsertTargetFactory.AdbInsertTarget<TInputError>(in DownstreamFactory<TInputError>, String, Action<IColumnMapperCommand>, IAdbConnectionBuilder, String)
    AdbInsertTargetFactory.AdbInsertTarget<TInputError>(in DownstreamFactory<TInputError>, String, IAdbConnectionBuilder, String)
    XlsxTargetFactory.XlsxTarget<TInput>(in DownstreamFactory<TInput>, String, Action<IXlsxTargetCommand>, String, XlsxTargetWriteOption)
    XlsxTargetFactory.XlsxTarget<TInput>(in DownstreamFactory<TInput>, String, Action<IXlsxTargetCommand>, String)
    FileHelperFileTargetFactory.FileHelperFileTarget<TInput>(in DownstreamFactory<TInput>, String, String)
    FileHelperStreamTargetFactory.FileHelperStreamTarget<TInput>(in DownstreamFactory<TInput>, String, TextWriter)
    AdbMySqlConnectorBulkInsertTargetFactory.AdbMySqlConnectorBulkInsertTarget<TInput>(in DownstreamFactory<TInput>, String, Action<IColumnMapperCommand>, IAdbConnectionBuilder, String)
    AdbSqlClientBulkInsertTargetFactory.AdbSqlClientBulkInsertTarget<TInput>(in DownstreamFactory<TInput>, String, Action<IColumnMapperCommand>, IAdbConnectionBuilder, SqlBulkCopyOptions, String)
    In This Article
    Back to top Copyright © 2021 Envobi Ltd