Title here
Summary here
public abstract class DataFlowDestination<TInput> : DataFlowComponent, IDataFlowLogging, IDataFlowDestination<TInput>, IDataFlowDestination, IDataFlowComponent, ILoggableTask
Name | Description |
---|---|
TInput |
protected BatchBlock<TInput> Buffer
Type | Description |
---|---|
BatchBlock<TInput> |
public const int DEFAULT_BATCH_SIZE = 1000
Type | Description |
---|---|
int |
protected int InternalBatchSize
Type | Description |
---|---|
int |
protected ActionBlock<TInput[]> BufferTargetAction { get; set; }
Type | Description |
---|---|
ActionBlock<TInput[]> |
protected ActionBlock<TInput> TargetAction { get; set; }
Type | Description |
---|---|
ActionBlock<TInput> |
TargetBlock from the underlying TPL.Dataflow which is used as output buffer for the component.
public ITargetBlock<TInput> TargetBlock { get; }
Type | Description |
---|---|
ITargetBlock<TInput> |
protected virtual bool UseBufferBlock { get; set; }
Type | Description |
---|---|
bool |
protected override void InitComponent()
protected virtual void WriteBatch(TInput[] data)
Type | Name | Description |
---|---|---|
TInput[] | data |