public abstract class DataFlowDestination<TInput> : DataFlowComponent, IDataFlowDestination<TInput>, IDataFlowDestination, IDataFlowComponent, ILoggableTask

    protected BatchBlock<TInput> Buffer

    public const int DEFAULT_BATCH_SIZE = 1000

    protected int InternalBatchSize

    protected ActionBlock<TInput[]> BufferTargetAction { get; set; }

    protected ActionBlock<TInput> TargetAction { get; set; }

    public ITargetBlock<TInput> TargetBlock { get; }

    protected virtual bool UseBufferBlock { get; set; }

    protected override void InitComponent()

    protected virtual void WriteBatch(TInput[] data)