Class TableDestination<TInput>

A data flow destination for inserting data into a couchbase bucket.

Inheritance
object
LoggableTask
DataFlowComponent
DataFlowDestination<TInput>
DataFlowBatchDestination<TInput>
TableDestination<TInput>
TableDestination
Implements
Inherited Members
Namespace: ETLBox.Azure.Tables
Assembly: ETLBox.Azure.Tables.dll
Syntax
    public class TableDestination<TInput> : DataFlowBatchDestination<TInput>, IDataFlowLogging, IDataFlowBatchDestination<TInput>, IDataFlowDestination<TInput>, IDataFlowBatchDestination, IDataFlowDestination, IDataFlowComponent, ILoggableTask
Type Parameters
NameDescription
TInput

Type of ingoing data.

Constructors

TableDestination()

Declaration
    public TableDestination()

TableDestination(int)

Declaration
    public TableDestination(int batchSize)
Parameters
TypeNameDescription
intbatchSize

TableDestination(string, string)

Declaration
    public TableDestination(string connectionString, string tableName)
Parameters
TypeNameDescription
stringconnectionString
stringtableName

Properties

ConnectionString

Connection string for the Azure Table Storage Account. Either provide the ConnectionString or an Endpoint (optionally with TokenCredential or TableSharedKeyCredential). Alternatively, you can provide an already existing TableClient instance.

Declaration
    public string ConnectionString { get; set; }
Property Value
TypeDescription
string

Endpoint

Endpoint uri for the Azure Table Storage Account. Either provide the ConnectionString or an Endpoint (optionally with TokenCredential or TableSharedKeyCredential). Alternatively, you can provide an already existing TableClient instance.

Declaration
    public Uri Endpoint { get; set; }
Property Value
TypeDescription
Uri

SetEntityActionOptions

Individual options for each entity. Use this action to configure if a recreds should be added, updated, deleted or upserted.

Declaration
    public Action<EntityActionOption, TInput> SetEntityActionOptions { get; set; }
Property Value
TypeDescription
Action<EntityActionOption, TInput>

TableClient

An existing TableClient which is then used for the connection. (No ConnectionString or Endpoint needed if this is provided)

Declaration
    public TableClient TableClient { get; set; }
Property Value
TypeDescription
TableClient

TableClientOptions

Client options used when creating the TableClient.

Declaration
    public TableClientOptions TableClientOptions { get; set; }
Property Value
TypeDescription
TableClientOptions

TableName

The name of an existing Table in which the data is written.

Declaration
    public string TableName { get; set; }
Property Value
TypeDescription
string

TableSharedKeyCredential

When providing an Endpoint, you can provide either a TableSharedKeyCredential or TokenCredential.

Declaration
    public TableSharedKeyCredential TableSharedKeyCredential { get; set; }
Property Value
TypeDescription
TableSharedKeyCredential

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
TypeDescription
string
Overrides

TokenCredential

When providing an Endpoint, you can provide either a TableSharedKeyCredential or TokenCredential.

Declaration
    public TokenCredential TokenCredential { get; set; }
Property Value
TypeDescription
TokenCredential

UseTransactionalBatch

If set to true, all records are inserted in a transactional batch. If any of the records in the batch is flawed, the whole batch will not be inserted. You can redirect erroneous batches using 'LinkErrorsTo()' when linking your components.

Declaration
    public bool UseTransactionalBatch { get; set; }
Property Value
TypeDescription
bool

Methods

BulkInsertData(TInput[])

Declaration
    protected override void BulkInsertData(TInput[] data)
Parameters
TypeNameDescription
TInput[]data
Overrides

CheckParameter()

Declaration
    protected override void CheckParameter()
Overrides

FinishWrite()

Declaration
    protected override void FinishWrite()
Overrides

PrepareParameter()

Declaration
    protected override void PrepareParameter()
Overrides

PrepareWrite()

Declaration
    protected override void PrepareWrite()
Overrides

Implements