Class DataFlowSource<TOutput>

Inheritance

System.Object

GenericTask

DataFlowTask

DataFlowSource<TOutput>

CustomSource<TOutput>

DbSource<TOutput>

MemorySource<TOutput>

DataFlowStreamSource<TOutput>

CrossJoin<TInput1, TInput2, TOutput>

Implements

ITask

Inherited Members

DataFlowTask._loggingThresholdRows

DataFlowTask.LoggingThresholdRows

DataFlowTask.ProgressCount

DataFlowTask.HasLoggingThresholdRows

DataFlowTask.ThresholdCount

DataFlowTask.NLogStart()

DataFlowTask.NLogFinish()

DataFlowTask.LogProgressBatch(Int32)

DataFlowTask.LogProgress()

GenericTask.TaskType

GenericTask.TaskName

GenericTask.NLogger

GenericTask.ConnectionManager

GenericTask.ConnectionType

GenericTask.QB

GenericTask.QE

GenericTask._disableLogging

GenericTask.DisableLogging

GenericTask.TaskHash

GenericTask.CopyTaskProperties(ITask)

System.Object.Equals(System.Object)

System.Object.Equals(System.Object, System.Object)

System.Object.GetHashCode()

System.Object.GetType()

System.Object.MemberwiseClone()

System.Object.ReferenceEquals(System.Object, System.Object)

System.Object.ToString()

Namespace: ETLBox.DataFlow

Assembly: ETLBox.dll

Syntax

public abstract class DataFlowSource<TOutput> : DataFlowTask, ITask

Type Parameters

Name	Description
TOutput

Properties

Buffer

Declaration

protected BufferBlock<TOutput> Buffer { get; set; }

Property Value

Type	Description
System.Threading.Tasks.Dataflow.BufferBlock<TOutput>

ErrorHandler

Declaration

public ErrorHandler ErrorHandler { get; set; }

Property Value

Type	Description
ErrorHandler

SourceBlock

Declaration

public ISourceBlock<TOutput> SourceBlock { get; }

Property Value

Type	Description
System.Threading.Tasks.Dataflow.ISourceBlock<TOutput>

Methods

Execute()

Declaration

public abstract void Execute()

ExecuteAsync()

Declaration

public Task ExecuteAsync()

Returns

Type	Description
System.Threading.Tasks.Task

LinkErrorTo(IDataFlowLinkTarget<ETLBoxError>)

Declaration

public void LinkErrorTo(IDataFlowLinkTarget<ETLBoxError> target)

Parameters

Type	Name	Description
IDataFlowLinkTarget<ETLBoxError>	target

LinkTo(IDataFlowLinkTarget<TOutput>)

Declaration

public IDataFlowLinkSource<TOutput> LinkTo(IDataFlowLinkTarget<TOutput> target)

Parameters

Type	Name	Description
IDataFlowLinkTarget<TOutput>	target

Returns

Type	Description
IDataFlowLinkSource<TOutput>

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

Declaration

public IDataFlowLinkSource<TOutput> LinkTo(IDataFlowLinkTarget<TOutput> target, Predicate<TOutput> predicate)

Parameters

Type	Name	Description
IDataFlowLinkTarget<TOutput>	target
System.Predicate<TOutput>	predicate

Returns

Type	Description
IDataFlowLinkSource<TOutput>

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

Declaration

public IDataFlowLinkSource<TOutput> LinkTo(IDataFlowLinkTarget<TOutput> target, Predicate<TOutput> rowsToKeep, Predicate<TOutput> rowsIntoVoid)

Parameters

Type	Name	Description
IDataFlowLinkTarget<TOutput>	target
System.Predicate<TOutput>	rowsToKeep
System.Predicate<TOutput>	rowsIntoVoid

Returns

Type	Description
IDataFlowLinkSource<TOutput>

LinkTo<TConvert>(IDataFlowLinkTarget<TOutput>)

Declaration

public IDataFlowLinkSource<TConvert> LinkTo<TConvert>(IDataFlowLinkTarget<TOutput> target)

Parameters

Type	Name	Description
IDataFlowLinkTarget<TOutput>	target

Returns

Type	Description
IDataFlowLinkSource<TConvert>

Type Parameters

Name	Description
TConvert

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

Declaration

public IDataFlowLinkSource<TConvert> LinkTo<TConvert>(IDataFlowLinkTarget<TOutput> target, Predicate<TOutput> predicate)

Parameters

Type	Name	Description
IDataFlowLinkTarget<TOutput>	target
System.Predicate<TOutput>	predicate

Returns

Type	Description
IDataFlowLinkSource<TConvert>

Type Parameters

Name	Description
TConvert

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

Declaration

public IDataFlowLinkSource<TConvert> LinkTo<TConvert>(IDataFlowLinkTarget<TOutput> target, Predicate<TOutput> rowsToKeep, Predicate<TOutput> rowsIntoVoid)

Parameters

Type	Name	Description
IDataFlowLinkTarget<TOutput>	target
System.Predicate<TOutput>	rowsToKeep
System.Predicate<TOutput>	rowsIntoVoid

Returns

Type	Description
IDataFlowLinkSource<TConvert>

Type Parameters

Name	Description
TConvert

Implements

ITask