Class CustomBatchSource<TOutput>
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.
Inherited Members
object.Equals(object)
object.Equals(object, object)
object.GetHashCode()
object.GetType()
object.MemberwiseClone()
object.ReferenceEquals(object, object)
object.ToString()
Namespace: ETLBox.DataFlow.Connectors
Assembly: ETLBox.dll
Syntax
public class CustomBatchSource<TOutput> : DataFlowExecutableSource<TOutput>, ILoggableTask, IDataFlowLogging, IDataFlowExecutableSource<TOutput>, IDataFlowSource<TOutput>, IDataFlowSource, IDataFlowComponent, IDataFlowExecutableSource
Type Parameters
| Name | Description |
|---|---|
| TOutput | Type of outgoing data. |
Constructors
CustomBatchSource()
Declaration
public CustomBatchSource()
CustomBatchSource(Func<int, IEnumerable<TOutput>>, Predicate<int>)
Declaration
public CustomBatchSource(Func<int, IEnumerable<TOutput>> readBatchFunc, Predicate<int> readingCompleted)
Parameters
| Type | Name | Description |
|---|---|---|
| System.Func<T, TResult><int, System.Collections.Generic.IEnumerable<T><TOutput>> | readBatchFunc | Sets the ReadBatchFunc |
| System.Predicate<T><int> | readingCompleted | Sets the ReadingCompleted |
Properties
ReadBatchFunc
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.
Declaration
public Func<int, IEnumerable<TOutput>> ReadBatchFunc { get; set; }
Property Value
| Type | Description |
|---|---|
| System.Func<T, TResult><int, System.Collections.Generic.IEnumerable<T><TOutput>> |
ReadingCompleted
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.
Declaration
public Predicate<int> ReadingCompleted { get; set; }
Property Value
| Type | Description |
|---|---|
| System.Predicate<T><int> |
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
OnExecutionDoAsyncWork()
Declaration
protected override void OnExecutionDoAsyncWork()
Overrides
ETLBox.DataFlow.DataFlowExecutableSource<TOutput>.OnExecutionDoAsyncWork()
OnExecutionDoSynchronousWork()
Declaration
protected override void OnExecutionDoSynchronousWork()
Overrides
ETLBox.DataFlow.DataFlowExecutableSource<TOutput>.OnExecutionDoSynchronousWork()