custombatchsource.md

title	description	draft	images	menu	weight	toc
CustomBatchSource	Details for Class CustomBatchSource (ETLBox.DataFlow)	false		api parent etlbox.dataflow	10129	false

{{< rawhtml >}}

        <article class="content wrap" id="_content" data-uid="ETLBox.DataFlow.CustomBatchSource">

Class CustomBatchSource

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.

Inheritance

object

LoggableTask

DataFlowComponent

DataFlowSource<ExpandoObject>

DataFlowExecutableSource<ExpandoObject>

CustomBatchSource<ExpandoObject>

CustomBatchSource

Implements

IDataFlowLogging

IDataFlowExecutableSource<ExpandoObject>

IDataFlowSource<ExpandoObject>

IDataFlowExecutableSource

IDataFlowSource

IDataFlowComponent

ILoggableTask

Inherited Members

CustomBatchSource<ExpandoObject>.ReadBatchFunc

CustomBatchSource<ExpandoObject>.ReadingCompleted

CustomBatchSource<ExpandoObject>.CheckParameter()

CustomBatchSource<ExpandoObject>.OnExecutionDoAsyncWork()

CustomBatchSource<ExpandoObject>.CleanUpOnSuccess()

CustomBatchSource<ExpandoObject>.CleanUpOnFaulted(Exception)

DataFlowExecutableSource<ExpandoObject>.Limit

DataFlowExecutableSource<ExpandoObject>.ProgressCountIsInLimit

DataFlowExecutableSource<ExpandoObject>.ProgressCountIsExceedingLimit

DataFlowExecutableSource<ExpandoObject>.SourceBlock

DataFlowExecutableSource<ExpandoObject>.Buffer

DataFlowExecutableSource<ExpandoObject>.SourceTask

DataFlowExecutableSource<ExpandoObject>.CompleteManually

DataFlowExecutableSource<ExpandoObject>.InitComponent()

DataFlowExecutableSource<ExpandoObject>.Execute()

DataFlowExecutableSource<ExpandoObject>.Execute(CancellationToken)

DataFlowExecutableSource<ExpandoObject>.ExecuteAsync()

DataFlowExecutableSource<ExpandoObject>.ExecuteAsync(CancellationToken)

DataFlowExecutableSource<ExpandoObject>.StartAsync(CancellationToken?)

DataFlowSource<ExpandoObject>.LinkTo(IDataFlowDestination<ExpandoObject>)

DataFlowSource<ExpandoObject>.LinkTo(IDataFlowDestination<ExpandoObject>, Predicate<ExpandoObject>)

DataFlowSource<ExpandoObject>.LinkTo(IDataFlowDestination<ExpandoObject>, Predicate<ExpandoObject>, Predicate<ExpandoObject>)

DataFlowSource<ExpandoObject>.LinkTo<TConvert>(IDataFlowDestination<ExpandoObject>)

DataFlowSource<ExpandoObject>.LinkTo<TConvert>(IDataFlowDestination<ExpandoObject>, Predicate<ExpandoObject>)

DataFlowSource<ExpandoObject>.LinkTo<TConvert>(IDataFlowDestination<ExpandoObject>, Predicate<ExpandoObject>, Predicate<ExpandoObject>)

DataFlowComponent.MaxBufferSize

DataFlowComponent.Predecessors

DataFlowComponent.Successors

DataFlowComponent.Completion

DataFlowComponent.BufferCancellationSource

DataFlowComponent.BufferCancellationToken

DataFlowComponent.WasComponentInitialized

DataFlowComponent.IsReadyForProcessing

DataFlowComponent.SetParentComponent(DataFlowComponent)

DataFlowComponent.LinkErrorTo(IDataFlowDestination<ETLBoxError>)

DataFlowComponent.InternalLinkTo<T>(IDataFlowDestination, object, object)

DataFlowComponent.ResetComponent()

DataFlowComponent.InitBufferObjects(CancellationToken?)

DataFlowComponent.Reset()

DataFlowComponent.PrepareParameterForCheck()

DataFlowComponent.InitCheckedParameter()

DataFlowComponent.OnInitialization

DataFlowComponent.OnCompletion

DataFlowComponent.OnException

DataFlowComponent.CompleteOrFaultBufferOnPredecessorCompletion(Task)

DataFlowComponent.Exception

DataFlowComponent.ErrorSource

DataFlowComponent.CancelBufferAndThrowOperationCanceledException()

DataFlowComponent.InternalLinkErrorTo(IDataFlowDestination<ETLBoxError>)

DataFlowComponent.ThrowOrRedirectError(Exception, string, string)

DataFlowComponent.ThrowErrorAndFaultNetwork(Exception, string)

DataFlowComponent.CancelComponent()

DataFlowComponent.ProgressCount

DataFlowComponent.OnProgress

DataFlowComponent.LoggingStartOnce()

DataFlowComponent.LoggingFinishOnce()

DataFlowComponent.LogProgressBatch_AfterThrowOrRedirectError(int)

DataFlowComponent.LogProgress_AfterThrowOrRedirectError()

LoggableTask.TaskType

LoggableTask.TaskName

LoggableTask.DisableLogging

LoggableTask.LogThreshold

LoggableTask.TaskHash

LoggableTask.LogInstance

LoggableTask.ParentTask

LoggableTask.LogTrace(string, params object[])

LoggableTask.LogDebug(string, params object[])

LoggableTask.LogInfo(string, params object[])

LoggableTask.LogInfoOrDebug(string, params object[])

LoggableTask.LogWarn(string, params object[])

LoggableTask.LogError(string, params object[])

LoggableTask.LogFatal(string, params object[])

object.Equals(object)

object.Equals(object, object)

object.GetHashCode()

object.GetType()

object.MemberwiseClone()

object.ReferenceEquals(object, object)

object.ToString()

Namespace: ETLBox.DataFlow

Assembly: ETLBox.dll

Syntax

{{< /rawhtml >}}

    public class CustomBatchSource : CustomBatchSource<ExpandoObject>, IDataFlowLogging, IDataFlowExecutableSource<ExpandoObject>, IDataFlowSource<ExpandoObject>, IDataFlowExecutableSource, IDataFlowSource, IDataFlowComponent, ILoggableTask

{{< rawhtml >}}

Constructors

CustomBatchSource()

Declaration

{{< /rawhtml >}}

    public CustomBatchSource()

{{< rawhtml >}}

CustomBatchSource(Func<int, IEnumerable<ExpandoObject>>, Predicate<int>)

Declaration

{{< /rawhtml >}}

    public CustomBatchSource(Func<int, IEnumerable<ExpandoObject>> readFunc, Predicate<int> readingCompleted)

{{< rawhtml >}}

Parameters

Type	Name	Description
Func<int, IEnumerable<ExpandoObject>>	readFunc
Predicate<int>	readingCompleted

Implements

IDataFlowLogging

IDataFlowExecutableSource<TOutput>

IDataFlowSource<TOutput>

IDataFlowExecutableSource

IDataFlowSource

IDataFlowComponent

ILoggableTask

{{< /rawhtml >}}