WhereTransformation<TInput>

Class WhereTransformation<TInput>

The WhereTransformation allows you to filter out rows where a defined predicate is false. By default the WhereTransformation will filter out null values.

Inheritance
DataFlowTransformation<TInput, TInput>
WhereTransformation<TInput>
Inherited Members
Namespace: ETLBox.DataFlow
Assembly: ETLBox.dll
Syntax
    public class WhereTransformation<TInput> : DataFlowTransformation<TInput, TInput>, IDataFlowTransformation<TInput, TInput>, IDataFlowSource<TInput>, IDataFlowSource, IDataFlowDestination<TInput>, IDataFlowDestination, IDataFlowComponent, ILoggableTask
Type Parameters
NameDescription
TInput

The type of ingoing data.

Constructors

WhereTransformation()

Declaration
    public WhereTransformation()

WhereTransformation(Predicate<TInput>)

Declaration
    public WhereTransformation(Predicate<TInput> predicate)
Parameters
TypeNameDescription
Predicate<TInput>predicate

Properties

FilteredCount

Numbers of rows that were filtered out.

Declaration
    public int FilteredCount { get; }
Property Value
TypeDescription
int

PassedCount

Numbers of rows that were kept.

Declaration
    public int PassedCount { get; }
Property Value
TypeDescription
int

Predicate

The predicate returns true for rows that should be kept. The default implementation of the predicate will filter out null values.

Declaration
    public Predicate<TInput> Predicate { get; set; }
Property Value
TypeDescription
Predicate<TInput>

SourceBlock

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

Declaration
    public override ISourceBlock<TInput> SourceBlock { get; }
Property Value
TypeDescription
ISourceBlock<TInput>
Overrides

TargetBlock

TargetBlock from the underlying TPL.Dataflow which is used as input buffer for the component.

Declaration
    public override ITargetBlock<TInput> TargetBlock { get; }
Property Value
TypeDescription
ITargetBlock<TInput>
Overrides

Methods

CheckParameter()

Declaration
    protected override void CheckParameter()
Overrides

CleanUpOnFaulted(Exception)

Declaration
    protected override void CleanUpOnFaulted(Exception e)
Parameters
TypeNameDescription
Exceptione
Overrides

CleanUpOnSuccess()

Declaration
    protected override void CleanUpOnSuccess()
Overrides

InitComponent()

Declaration
    protected override void InitComponent()
Overrides

Reset()

Declaration
    protected override void Reset()
Overrides

Implements