ETLBox
Title here
Summary here
CouchbaseSource<TOutput>
Class CouchbaseSource<TOutput>
A data flow source for Couchbase
Inherited Members
Namespace: ETLBox.Couchbase
Assembly: ETLBox.Couchbase.dll
Syntax
public class CouchbaseSource<TOutput> : DataFlowExecutableSource<TOutput>, IDataFlowExecutableSource<TOutput>, IDataFlowSource<TOutput>, IDataFlowExecutableSource, IDataFlowSource, IDataFlowComponent, ILoggableTaskType Parameters
| Name | Description |
|---|---|
| TOutput | Type of outgoing data. |
Constructors
CouchbaseSource()
Declaration
public CouchbaseSource()Properties
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 |
|---|---|
| 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 |
|---|---|
| string |
CouchbaseCluster
An existing couchbase Cluster that holds a couchbase connection.
Declaration
public ICluster CouchbaseCluster { get; set; }Property Value
| Type | Description |
|---|---|
| ICluster |
N1QLStatement
The N1QL statement used to retrieve data from your Couchbase DB. Objects will be deserialized from json.
Declaration
public string N1QLStatement { get; set; }Property Value
| Type | Description |
|---|---|
| string |
Options
Additional query options when retrieving data with the N1QLStatement
Declaration
public QueryOptions Options { get; set; }Property Value
| Type | Description |
|---|---|
| QueryOptions |
Methods
CheckParameter()
Declaration
protected override void CheckParameter()Overrides
CleanUpOnFaulted(Exception)
Declaration
protected override void CleanUpOnFaulted(Exception e)Parameters
| Type | Name | Description |
|---|---|---|
| Exception | e |
Overrides
CleanUpOnSuccess()
Declaration
protected override void CleanUpOnSuccess()Overrides
InitCheckedParameter()
Declaration
protected override void InitCheckedParameter()Overrides
OnExecutionDoAsyncWork()
Declaration
protected override void OnExecutionDoAsyncWork()Overrides
Reset()
Declaration
protected override void Reset()