Class TableSource<TOutput>

A data flow source for Couchbase

Inheritance
object
LoggableTask
DataFlowComponent
DataFlowSource<TOutput>
DataFlowExecutableSource<TOutput>
TableSource<TOutput>
TableSource
Implements
Inherited Members
Namespace: ETLBox.Azure.Tables
Assembly: ETLBox.Azure.Tables.dll
Syntax
    public class TableSource<TOutput> : DataFlowExecutableSource<TOutput>, IDataFlowLogging, IDataFlowExecutableSource<TOutput>, IDataFlowSource<TOutput>, IDataFlowExecutableSource, IDataFlowSource, IDataFlowComponent, ILoggableTask
Type Parameters
NameDescription
TOutput

Type of outgoing data.

Constructors

TableSource()

Declaration
    public TableSource()

TableSource(string, string)

Declaration
    public TableSource(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

Filter

Returns only entities that satisfy the specified filter expression. For example, the following expression would filter entities with a PartitionKey of 'foo': e => e.PartitionKey == "foo".

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

MaxPerPage

The maximum number of entities that will be returned per page. Note: This value does not limit the total number of results if the result is fully enumerated.

Declaration
    public int? MaxPerPage { get; set; }
Property Value
TypeDescription
int?

Select

An IEnumerable<T> of entity property names that selects which set of entity properties to return in the result set. For example, the following value would return only the PartitionKey and RowKey properties: new[] { "PartitionKey, RowKey"}.

Declaration
    public IEnumerable<string> Select { get; set; }
Property Value
TypeDescription
IEnumerable<string>

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

TokenCredential

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

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

Methods

CheckParameter()

Declaration
    protected override void CheckParameter()
Overrides

CleanUpOnFaulted(Exception)

Declaration
    protected override void CleanUpOnFaulted(Exception e)
Parameters
TypeNameDescription
Exceptione
Overrides

CleanUpOnSuccess()

Declaration
    protected override void CleanUpOnSuccess()
Overrides

InitCheckedParameter()

Declaration
    protected override void InitCheckedParameter()
Overrides

OnExecutionDoAsyncWork()

Declaration
    protected override void OnExecutionDoAsyncWork()
Overrides

PrepareParameterForCheck()

Declaration
    protected override void PrepareParameterForCheck()
Overrides

Implements