ETLBox
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.
Implements
IDataFlowTransformation<TInput, TInput>
IDataFlowSource<TInput>
IDataFlowDestination<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, ILoggableTaskType Parameters
| Name | Description |
|---|---|
| TInput | The type of ingoing data. |
Constructors
WhereTransformation()
Declaration
public WhereTransformation()WhereTransformation(Predicate<TInput>)
Declaration
public WhereTransformation(Predicate<TInput> predicate)Parameters
| Type | Name | Description |
|---|---|---|
| Predicate<TInput> | predicate |
Properties
FilteredCount
Numbers of rows that were filtered out.
Declaration
public int FilteredCount { get; }Property Value
| Type | Description |
|---|---|
| int |
PassedCount
Numbers of rows that were kept.
Declaration
public int PassedCount { get; }Property Value
| Type | Description |
|---|---|
| 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
| Type | Description |
|---|---|
| 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
| Type | Description |
|---|---|
| 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
| Type | Description |
|---|---|
| ITargetBlock<TInput> |
Overrides
Methods
CheckParameter()
Declaration
protected override void CheckParameter()Overrides
CleanUpOnFaulted(Exception)
Declaration
protected override void CleanUpOnFaulted(Exception e)Parameters
| Type | Name | Description |
|---|---|---|
| Exception | e |
Overrides
CleanUpOnSuccess()
Declaration
protected override void CleanUpOnSuccess()Overrides
CompleteBuffer()
Declaration
protected override void CompleteBuffer()Overrides
FaultBuffer(Exception)
Declaration
protected override void FaultBuffer(Exception e)Parameters
| Type | Name | Description |
|---|---|---|
| Exception | e |
Overrides
InitComponent()
Declaration
protected override void InitComponent()Overrides
Reset()
Declaration
protected override void Reset()