CouchbaseDestination<TInput>

Class CouchbaseDestination<TInput>

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

Inherited Members
Namespace: ETLBox.Couchbase
Assembly: ETLBox.Couchbase.dll
Syntax
    public class CouchbaseDestination<TInput> : DataFlowBatchDestination<TInput>, IDataFlowBatchDestination<TInput>, IDataFlowDestination<TInput>, IDataFlowBatchDestination, IDataFlowDestination, IDataFlowComponent, ILoggableTask
Type Parameters
NameDescription
TInput

Type of ingoing data.

Constructors

CouchbaseDestination()

Declaration
    public CouchbaseDestination()

CouchbaseDestination(int)

Declaration
    public CouchbaseDestination(int batchSize)
Parameters
TypeNameDescription
intbatchSize

Properties

BucketName

The bucket name to insert the data into. Object will be serialized into Json.

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

ClusterOptions

If you provide ClusterOptions (or a connection string), this component will create a new Cluster object to connect with Couchbase. If you already have a cluster object instantiated in your application, use CouchbaseCluster instead to pass it directly to the component. Instead or additional to a ClustOptions you can also set the ConnectionString.

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

ConnectionString

If you provide a connection string (or cluster options), this component will create a new Cluster object to connect with Couchbase. If you already have a cluster object instantiated in your application, use CouchbaseCluster instead to pass it directly to the component. Instead or additional to a connection string you can also set the ClusterOptions.

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

CouchbaseCluster

An existing couchbase Cluster that holds a couchbase connection.

Declaration
    public ICluster CouchbaseCluster { get; set; }
Property Value
TypeDescription
ICluster

KeyColumn

The property that is used to retrieve the key. Only one key column is accepted. If no key column is provided, a Guid is generated and used as key. The property that hold the key must either be a string or implement ToString().

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

Options

Additional insert options to use when inserted data into the bucket.

Declaration
    public InsertOptions Options { get; set; }
Property Value
TypeDescription
InsertOptions

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

PrepareParameterForCheck()

Declaration
    protected override void PrepareParameterForCheck()
Overrides

PrepareWrite()

Declaration
    protected override void PrepareWrite()
Overrides

Reset()

Declaration
    protected override void Reset()
Overrides

Implements