Class Distinct<TInput>
Implements
Inherited Members
Namespace: ETLBox.DataFlow.Transformations
Assembly: ETLBox.dll
Syntax
public class Distinct<TInput> : DataFlowTransformation<TInput, TInput>, ILoggableTask, IDataFlowLogging, IDataFlowTransformation<TInput, TInput>, IDataFlowSource<TInput>, IDataFlowSource, IDataFlowDestination<TInput>, IDataFlowDestination, IDataFlowComponent
Type Parameters
| Name | Description |
|---|---|
| TInput |
Constructors
Distinct()
Declaration
public Distinct()
Properties
DistinctColumns
Defines the property names that should be used to determine the uniqueness of an object.
Declaration
public ICollection<DistinctColumn> DistinctColumns { get; set; }
Property Value
| Type | Description |
|---|---|
| System.Collections.Generic.ICollection<T><DistinctColumn> |
DuplicatesSourceBlock
Declaration
public ISourceBlock<TInput> DuplicatesSourceBlock { get; }
Property Value
| Type | Description |
|---|---|
| System.Threading.Tasks.Dataflow.ISourceBlock<TOutput><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 |
|---|---|
| System.Threading.Tasks.Dataflow.ISourceBlock<TOutput><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 |
|---|---|
| System.Threading.Tasks.Dataflow.ITargetBlock<TInput><TInput> |
Overrides
TaskName
A name to identify the task or component. Every component or task comes with a default name that can be overwritten.
Declaration
public override string TaskName { get; set; }
Property Value
| Type | Description |
|---|---|
| string |
Overrides
Methods
CheckParameter()
Declaration
protected override void CheckParameter()
Overrides
CleanUpOnFaulted(Exception)
Declaration
protected override void CleanUpOnFaulted(Exception e)
Parameters
| Type | Name | Description |
|---|---|---|
| System.Exception | e |
Overrides
CleanUpOnSuccess()
Declaration
protected override void CleanUpOnSuccess()
Overrides
InitComponent()
Declaration
protected override void InitComponent()
Overrides
InitParameter()
Declaration
protected override void InitParameter()
Overrides
LinkDuplicatesTo(IDataFlowDestination<TInput>, Predicate<TInput>, Predicate<TInput>)
Links the current block to another transformation or destination, which will only receive the detected duplicates.
Declaration
public virtual IDataFlowSource<TInput> LinkDuplicatesTo(IDataFlowDestination<TInput> target, Predicate<TInput> rowsToKeep, Predicate<TInput> rowsIntoVoid)
Parameters
| Type | Name | Description |
|---|---|---|
| IDataFlowDestination<TInput> | target | Transformation or destination that the block is linked to. |
| System.Predicate<T><TInput> | rowsToKeep | Only rows that evaluate to true are send to the connected target |
| System.Predicate<T><TInput> | rowsIntoVoid | Rows that are evaluate to true will be discarded |
Returns
| Type | Description |
|---|---|
| IDataFlowSource<TInput> | The linked component. |
LinkDuplicatesTo(IDataFlowDestination<TInput>, Predicate<TInput>)
Links the current block to another transformation or destination, which will only receive the detected duplicates.
Declaration
public virtual IDataFlowSource<TInput> LinkDuplicatesTo(IDataFlowDestination<TInput> target, Predicate<TInput> rowsToKeep)
Parameters
| Type | Name | Description |
|---|---|---|
| IDataFlowDestination<TInput> | target | Transformation or destination that the block is linked to. |
| System.Predicate<T><TInput> | rowsToKeep | Only rows that evaluate to true are send to the connected target |
Returns
| Type | Description |
|---|---|
| IDataFlowSource<TInput> | The linked component. |
LinkDuplicatesTo(IDataFlowDestination<TInput>)
Links the current block to another transformation or destination, which will only receive the detected duplicates.
Declaration
public IDataFlowSource<TInput> LinkDuplicatesTo(IDataFlowDestination<TInput> target)
Parameters
| Type | Name | Description |
|---|---|---|
| IDataFlowDestination<TInput> | target | Transformation or destination that the block is linked to. |
Returns
| Type | Description |
|---|---|
| IDataFlowSource<TInput> | The linked component. |
PrepareParameter()
Declaration
protected override void PrepareParameter()