RowValidation<TInput>

Class RowValidation<TInput>

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

Constructors

RowValidation()

Declaration
    public RowValidation()

Properties

AddValidationErrorToRow

Declaration
    public bool AddValidationErrorToRow { get; set; }
Property Value
TypeDescription
bool

IgnoreMissingProperties

Declaration
    public bool IgnoreMissingProperties { get; set; }
Property Value
TypeDescription
bool

InvalidSourceBlock

Declaration
    public ISourceBlock<TInput> InvalidSourceBlock { get; }
Property Value
TypeDescription
ISourceBlock<TInput>

SkipValidationOfRowAfterFirstError

Declaration
    public bool SkipValidationOfRowAfterFirstError { get; set; }
Property Value
TypeDescription
bool

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

ValidateColumns

Declaration
    public ICollection<ValidateColumn> ValidateColumns { get; set; }
Property Value
TypeDescription
ICollection<ValidateColumn>

ValidateRowFunc

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

Methods

AddAutomaticVoidLinkToOtherTargets(DataFlowComponent, IDataFlowDestination)

Declaration
    protected override void AddAutomaticVoidLinkToOtherTargets(DataFlowComponent key, IDataFlowDestination voidDest)
Parameters
TypeNameDescription
DataFlowComponentkey
IDataFlowDestinationvoidDest
Overrides

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

LinkInvalidTo(IDataFlowDestination<TInput>)

Establishes a link from the current block to another transformation or destination. This linked component will exclusively receive the invalid rows detected by the current block.

Declaration
    public IDataFlowSource<TInput> LinkInvalidTo(IDataFlowDestination<TInput> target)
Parameters
TypeNameDescription
IDataFlowDestination<TInput>target

The transformation or destination to which this block is linked.

Returns
TypeDescription
IDataFlowSource<TInput>

The component to which the invalid rows are linked.

LinkInvalidTo(IDataFlowDestination<TInput>, Predicate<TInput>)

Establishes a link from the current block to another transformation or destination. This linked component will exclusively receive the invalid rows detected by the current block.

Declaration
    public virtual IDataFlowSource<TInput> LinkInvalidTo(IDataFlowDestination<TInput> target, Predicate<TInput> rowsToKeep)
Parameters
TypeNameDescription
IDataFlowDestination<TInput>target

The transformation or destination to which this block is linked.

Predicate<TInput>rowsToKeep

A predicate to determine which rows to send to the connected target. Rows that satisfy this predicate (evaluate to true) are forwarded.

Returns
TypeDescription
IDataFlowSource<TInput>

The component to which the invalid rows are linked.

LinkInvalidTo(IDataFlowDestination<TInput>, Predicate<TInput>, Predicate<TInput>)

Establishes a link from the current block to another transformation or destination. This linked component will exclusively receive the invalid rows detected by the current block.

Declaration
    public virtual IDataFlowSource<TInput> LinkInvalidTo(IDataFlowDestination<TInput> target, Predicate<TInput> rowsToKeep, Predicate<TInput> rowsIntoVoid)
Parameters
TypeNameDescription
IDataFlowDestination<TInput>target

The transformation or destination to which this block is linked.

Predicate<TInput>rowsToKeep

A predicate to determine which rows to send to the connected target. Rows that satisfy this predicate (evaluate to true) are forwarded.

Predicate<TInput>rowsIntoVoid

A predicate to filter out rows. Rows that satisfy this predicate (evaluate to true) are discarded.

Returns
TypeDescription
IDataFlowSource<TInput>

The component to which the invalid rows are linked.

PrepareParameterForCheck()

Declaration
    protected override void PrepareParameterForCheck()
Overrides

Reset()

Declaration
    protected override void Reset()
Overrides

Implements