IDataFlowSource<TOutput>

Interface IDataFlowSource<TOutput>

Shared methods for linking of source components

Namespace: ETLBox
Assembly: ETLBox.dll
Syntax
    public interface IDataFlowSource<TOutput> : IDataFlowSource, IDataFlowComponent, ILoggableTask
Type Parameters
NameDescription
TOutput

Type of outgoing data

Properties

SourceBlock

SourceBlock from the underlying TPL.Dataflow which is used as output buffer for the component.

Declaration
    ISourceBlock<TOutput> SourceBlock { get; }
Property Value
TypeDescription
ISourceBlock<TOutput>

Methods

LinkTo(IDataFlowDestination<TOutput>)

Links the current block to another transformation or destination. Every component should be linked to only one component without predicates If you want to link multiple targets, either use predicates or a Multicast

Declaration
    IDataFlowSource<TOutput> LinkTo(IDataFlowDestination<TOutput> target)
Parameters
TypeNameDescription
IDataFlowDestination<TOutput>target

Transformation or destination that the block is linked to.

Returns
TypeDescription
IDataFlowSource<TOutput>

The linked component.

LinkTo(IDataFlowDestination<TOutput>, Predicate<TOutput>)

Links the current block to another transformation or destination with a predicate. Every component can be linked to one or more component. If you link multiple components, provide a Predicate<T> that describe which row is send to which target. Make sure that all rows will be send to a target - use the VoidDestination if you want to discarded rows.

Declaration
    IDataFlowSource<TOutput> LinkTo(IDataFlowDestination<TOutput> target, Predicate<TOutput> rowsToKeep)
Parameters
TypeNameDescription
IDataFlowDestination<TOutput>target

Transformation or destination that the block is linked to.

Predicate<TOutput>rowsToKeep

Only rows that evaluate to true are send to the connected target

Returns
TypeDescription
IDataFlowSource<TOutput>

The linked component.

LinkTo(IDataFlowDestination<TOutput>, Predicate<TOutput>, Predicate<TOutput>)

Links the current block to another transformation or destination with a predicate for rows that you want to keep and a second predicate for rows you want to discard.

Declaration
    IDataFlowSource<TOutput> LinkTo(IDataFlowDestination<TOutput> target, Predicate<TOutput> rowsToKeep, Predicate<TOutput> rowsIntoVoid)
Parameters
TypeNameDescription
IDataFlowDestination<TOutput>target

Transformation or destination that the block is linked to.

Predicate<TOutput>rowsToKeep

Only rows that evaluate to true are send to the connected target

Predicate<TOutput>rowsIntoVoid

Rows that are evaluate to true will be discarded

Returns
TypeDescription
IDataFlowSource<TOutput>

The linked component.

LinkTo<TConvert>(IDataFlowDestination<TOutput>)

Links the current block to another transformation or destination. Every component should be linked to only one component without predicates If you want to link multiple targets, either use predicates or a Multicast

Declaration
    IDataFlowSource<TConvert> LinkTo<TConvert>(IDataFlowDestination<TOutput> target)
Parameters
TypeNameDescription
IDataFlowDestination<TOutput>target

Transformation or destination that the block is linked to.

Returns
TypeDescription
IDataFlowSource<TConvert>

The linked component.

Type Parameters
NameDescription
TConvert

Will convert the output type of the linked component.

LinkTo<TConvert>(IDataFlowDestination<TOutput>, Predicate<TOutput>)

Links the current block to another transformation or destination with a predicate. Every component can be linked to one or more component. If you link multiple components, provide a Predicate<T> that describe which row is send to which target. Make sure that all rows will be send to a target - use the VoidDestination if you want to discarded rows.

Declaration
    IDataFlowSource<TConvert> LinkTo<TConvert>(IDataFlowDestination<TOutput> target, Predicate<TOutput> rowsToKeep)
Parameters
TypeNameDescription
IDataFlowDestination<TOutput>target

Transformation or destination that the block is linked to.

Predicate<TOutput>rowsToKeep

Predicate - only rows that evaluate to true are send to the connected target

Returns
TypeDescription
IDataFlowSource<TConvert>

The linked component.

Type Parameters
NameDescription
TConvert

Will convert the output type of the linked component.

LinkTo<TConvert>(IDataFlowDestination<TOutput>, Predicate<TOutput>, Predicate<TOutput>)

Links the current block to another transformation or destination with a predicate for rows that you want to keep and a second predicate for rows you want to discard.

Declaration
    IDataFlowSource<TConvert> LinkTo<TConvert>(IDataFlowDestination<TOutput> target, Predicate<TOutput> rowsToKeep, Predicate<TOutput> rowsIntoVoid)
Parameters
TypeNameDescription
IDataFlowDestination<TOutput>target

Transformation or destination that the block is linked to.

Predicate<TOutput>rowsToKeep

Only rows that evaluate to true are send to the connected target

Predicate<TOutput>rowsIntoVoid

Rows that are evaluate to true will be discarded

Returns
TypeDescription
IDataFlowSource<TConvert>

The linked component.

Type Parameters
NameDescription
TConvert

Will convert the output type of the linked component.