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, ILoggableTask
Type Parameters
NameDescription
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
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

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

Options

Additional query options when retrieving data with the N1QLStatement

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

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

Reset()

Declaration
    protected override void Reset()
Overrides

Implements