Title here
Summary here
Define your own source block. This block allows you to read batches of data from your own custom written functions, which are then send subsequently into your data flow.
public class CustomBatchSource<TOutput> : DataFlowExecutableSource<TOutput>, IDataFlowExecutableSource<TOutput>, IDataFlowSource<TOutput>, IDataFlowExecutableSource, IDataFlowSource, IDataFlowComponent, ILoggableTask
Name | Description |
---|---|
TOutput | Type of outgoing data. |
public CustomBatchSource()
public CustomBatchSource(Func<int, IEnumerable<TOutput>> readBatchFunc, Predicate<int> readingCompleted)
Type | Name | Description |
---|---|---|
Func<int, IEnumerable<TOutput>> | readBatchFunc | Sets the ReadBatchFunc |
Predicate<int> | readingCompleted | Sets the ReadingCompleted |
The function that returns a batch of data row as output. An integer value with the current progress count is the input of the function.
public Func<int, IEnumerable<TOutput>> ReadBatchFunc { get; set; }
Type | Description |
---|---|
Func<int, IEnumerable<TOutput>> |
This predicate returns true when all rows for the flow are successfully returned from the ReadBatchFunc. An integer value with the current progress count is the input of the predicate.
public Predicate<int> ReadingCompleted { get; set; }
Type | Description |
---|---|
Predicate<int> |
protected override void CheckParameter()
protected override void CleanUpOnFaulted(Exception e)
Type | Name | Description |
---|---|---|
Exception | e |
protected override void CleanUpOnSuccess()
protected override void OnExecutionDoAsyncWork()