Class CouchbaseDestination<TInput>
A data flow destination for inserting data into a couchbase bucket.
Inheritance
System.Object
CouchbaseDestination<TInput>
Inherited Members
System.Object.Equals(System.Object)
System.Object.Equals(System.Object, System.Object)
System.Object.GetHashCode()
System.Object.GetType()
System.Object.MemberwiseClone()
System.Object.ReferenceEquals(System.Object, System.Object)
System.Object.ToString()
Namespace: ETLBox.DataFlow.Connectors
Assembly: ETLBox.Couchbase.dll
Syntax#
public class CouchbaseDestination<TInput> : DataFlowBatchDestination<TInput>, ILoggableTask, IDataFlowLogging, IDataFlowBatchDestination<TInput>, IDataFlowDestination<TInput>, IDataFlowDestination, IDataFlowComponent, IDataFlowBatchDestination
Type Parameters
| Name | Description |
|---|
| TInput | Type of ingoing data. |
Constructors
CouchbaseDestination()#
Declaration
public CouchbaseDestination()
CouchbaseDestination(Int32)#
Declaration
public CouchbaseDestination(int batchSize)
Parameters
| Type | Name | Description |
|---|
| System.Int32 | batchSize | |
Properties
BucketName#
The bucket name to insert the data into. Object will be serialized into Json.
Declaration
public string BucketName { get; set; }
Property Value
| Type | Description |
|---|
| System.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
| Type | Description |
|---|
| Couchbase.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
| Type | Description |
|---|
| System.String | |
CouchbaseCluster#
An existing couchbase Cluster that holds a couchbase connection.
Declaration
public ICluster CouchbaseCluster { get; set; }
Property Value
| Type | Description |
|---|
| Couchbase.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
Options#
Additional insert options to use when inserted data into the bucket.
Declaration
public InsertOptions Options { get; set; }
Property Value
| Type | Description |
|---|
| Couchbase.KeyValue.InsertOptions | |
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
| Type | Description |
|---|
| System.String | |
Overrides
Methods
BulkInsertData(TInput[])#
Declaration
protected override void BulkInsertData(TInput[] data)
Parameters
| Type | Name | Description |
|---|
| TInput[] | data | |
Overrides
ETLBox.DataFlow.DataFlowBatchDestination<TInput>.BulkInsertData(TInput[])
CheckParameter()#
Declaration
protected override void CheckParameter()
Overrides
FinishWrite()#
Declaration
protected override void FinishWrite()
Overrides
ETLBox.DataFlow.DataFlowBatchDestination<TInput>.FinishWrite()
PrepareParameter()#
Declaration
protected override void PrepareParameter()
Overrides
PrepareWrite()#
Declaration
protected override void PrepareWrite()
Overrides
ETLBox.DataFlow.DataFlowBatchDestination<TInput>.PrepareWrite()
Implements#
ETLBox