CosmosSource

Class CosmosSource

A data flow source for Couchbase

Inheritance

DataFlowComponent

DataFlowSource<ExpandoObject>

DataFlowExecutableSource<ExpandoObject>

CosmosSource<ExpandoObject>

CosmosSource

Implements

IDataFlowExecutableSource<ExpandoObject>

IDataFlowSource<ExpandoObject>

IDataFlowExecutableSource

IDataFlowSource

IDataFlowComponent

Inherited Members

CosmosSource<ExpandoObject>.ConnectionString

CosmosSource<ExpandoObject>.AzureKeyCredential

CosmosSource<ExpandoObject>.AzureTokenCredential

CosmosSource<ExpandoObject>.AccountEndpoint

CosmosSource<ExpandoObject>.AuthKeyOrResourceToken

CosmosSource<ExpandoObject>.DatabaseName

CosmosSource<ExpandoObject>.ContainerName

CosmosSource<ExpandoObject>.CosmosClient

CosmosSource<ExpandoObject>.Sql

CosmosSource<ExpandoObject>.QueryDefinition

CosmosSource<ExpandoObject>.QueryRequestOptions

CosmosSource<ExpandoObject>.PrepareParameterForCheck()

CosmosSource<ExpandoObject>.CheckParameter()

CosmosSource<ExpandoObject>.InitCheckedParameter()

CosmosSource<ExpandoObject>.OnExecutionDoAsyncWork()

CosmosSource<ExpandoObject>.CleanUpOnSuccess()

CosmosSource<ExpandoObject>.CleanUpOnFaulted(Exception)

DataFlowExecutableSource<ExpandoObject>.Limit

DataFlowExecutableSource<ExpandoObject>.ProgressCountIsInLimit

DataFlowExecutableSource<ExpandoObject>.ProgressCountIsExceedingLimit

DataFlowExecutableSource<ExpandoObject>.SourceBlock

DataFlowExecutableSource<ExpandoObject>.Buffer

DataFlowExecutableSource<ExpandoObject>.SourceTask

DataFlowExecutableSource<ExpandoObject>.CompleteManually

DataFlowExecutableSource<ExpandoObject>.InitComponent()

DataFlowExecutableSource<ExpandoObject>.Execute()

DataFlowExecutableSource<ExpandoObject>.Execute(CancellationToken)

DataFlowExecutableSource<ExpandoObject>.ExecuteAsync()

DataFlowExecutableSource<ExpandoObject>.ExecuteAsync(CancellationToken)

DataFlowExecutableSource<ExpandoObject>.StartAsync(CancellationToken?)

DataFlowSource<ExpandoObject>.LinkTo(IDataFlowDestination<ExpandoObject>)

DataFlowSource<ExpandoObject>.LinkTo(IDataFlowDestination<ExpandoObject>, Predicate<ExpandoObject>)

DataFlowSource<ExpandoObject>.LinkTo(IDataFlowDestination<ExpandoObject>, Predicate<ExpandoObject>, Predicate<ExpandoObject>)

DataFlowSource<ExpandoObject>.LinkTo<TConvert>(IDataFlowDestination<ExpandoObject>)

DataFlowSource<ExpandoObject>.LinkTo<TConvert>(IDataFlowDestination<ExpandoObject>, Predicate<ExpandoObject>)

DataFlowSource<ExpandoObject>.LinkTo<TConvert>(IDataFlowDestination<ExpandoObject>, Predicate<ExpandoObject>, Predicate<ExpandoObject>)

DataFlowComponent.MaxBufferSize

DataFlowComponent.Predecessors

DataFlowComponent.Successors

DataFlowComponent.Completion

DataFlowComponent.BufferCancellationSource

DataFlowComponent.BufferCancellationToken

DataFlowComponent.WasComponentInitialized

DataFlowComponent.IsReadyForProcessing

DataFlowComponent.SetParentComponent(DataFlowComponent)

DataFlowComponent.LinkErrorTo(IDataFlowDestination<ETLBoxError>)

DataFlowComponent.InternalLinkTo<T>(IDataFlowDestination, object, object)

DataFlowComponent.AddComplementVoidLinkToOtherTargets(Func<Type, IDataFlowDestination>, Delegate)

DataFlowComponent.ResetComponent()

DataFlowComponent.InitBufferObjects(CancellationToken?)

DataFlowComponent.Reset()

DataFlowComponent.OnInitialization

DataFlowComponent.OnCompletion

DataFlowComponent.OnException

DataFlowComponent.CompleteOrFaultBufferOnPredecessorCompletion(Task)

DataFlowComponent.Exception

DataFlowComponent.ErrorSource

DataFlowComponent.CancelBufferAndThrowOperationCanceledException()

DataFlowComponent.InternalLinkErrorTo(IDataFlowDestination<ETLBoxError>)

DataFlowComponent.ThrowOrRedirectError(Exception, string, string)

DataFlowComponent.ThrowErrorAndFaultNetwork(Exception, string)

DataFlowComponent.CancelComponent()

DataFlowComponent.ErrorCount

DataFlowComponent.ProgressCount

DataFlowComponent.OnProgress

DataFlowComponent.ExecutionStartTime

DataFlowComponent.ExecutionEndTime

DataFlowComponent.Tag

DataFlowComponent.LoggingStartOnce()

DataFlowComponent.LoggingFinishOnce()

DataFlowComponent.LogProgressBatch_AfterThrowOrRedirectError(int)

DataFlowComponent.LogProgress_AfterThrowOrRedirectError()

LoggableTask.TaskType

LoggableTask.TaskName

LoggableTask.DisableLogging

LoggableTask.LogThreshold

LoggableTask.TaskHash

LoggableTask.LogInstance

LoggableTask.ParentTask

LoggableTask.LogTrace(string, params object[])

LoggableTask.LogDebug(string, params object[])

LoggableTask.LogInfo(string, params object[])

LoggableTask.LogInfoOrDebug(string, params object[])

LoggableTask.LogWarn(string, params object[])

LoggableTask.LogError(string, params object[])

LoggableTask.LogFatal(string, params object[])

object.Equals(object)

object.Equals(object, object)

object.GetHashCode()

object.GetType()

object.MemberwiseClone()

object.ReferenceEquals(object, object)

object.ToString()

Namespace: ETLBox.Azure.CosmosDb

Assembly: ETLBox.Azure.CosmosDb.dll

Syntax

    public class CosmosSource : CosmosSource<ExpandoObject>, IDataFlowExecutableSource<ExpandoObject>, IDataFlowSource<ExpandoObject>, IDataFlowExecutableSource, IDataFlowSource, IDataFlowComponent, ILoggableTask

Constructors

CosmosSource()

Declaration

    public CosmosSource()

CosmosSource(string, string, string, string)

Declaration

    public CosmosSource(string connectionString, string databaseName, string containerName, string sql)

Parameters

Type	Name	Description
string	connectionString
string	databaseName
string	containerName
string	sql

Implements

IDataFlowExecutableSource<TOutput>

IDataFlowSource<TOutput>

IDataFlowExecutableSource

IDataFlowSource

IDataFlowComponent