CosmosDestination

Class CosmosDestination

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

Inheritance

DataFlowComponent

DataFlowDestination<ExpandoObject>

DataFlowBatchDestination<ExpandoObject>

CosmosDestination<ExpandoObject>

CosmosDestination

Implements

IDataFlowBatchDestination<ExpandoObject>

IDataFlowDestination<ExpandoObject>

IDataFlowBatchDestination

IDataFlowDestination

IDataFlowComponent

Inherited Members

CosmosDestination<ExpandoObject>.ConnectionString

CosmosDestination<ExpandoObject>.AzureKeyCredential

CosmosDestination<ExpandoObject>.AzureTokenCredential

CosmosDestination<ExpandoObject>.AccountEndpoint

CosmosDestination<ExpandoObject>.AuthKeyOrResourceToken

CosmosDestination<ExpandoObject>.DatabaseName

CosmosDestination<ExpandoObject>.ContainerName

CosmosDestination<ExpandoObject>.CosmosClient

CosmosDestination<ExpandoObject>.UseTransactionalBatch

CosmosDestination<ExpandoObject>.SetItemActionOptions

CosmosDestination<ExpandoObject>.PrepareParameterForCheck()

CosmosDestination<ExpandoObject>.CheckParameter()

CosmosDestination<ExpandoObject>.PrepareWrite()

CosmosDestination<ExpandoObject>.BulkInsertData(ExpandoObject[])

CosmosDestination<ExpandoObject>.FinishWrite()

DataFlowBatchDestination<ExpandoObject>.BeforeBatchWrite

DataFlowBatchDestination<ExpandoObject>.AfterBatchWrite

DataFlowBatchDestination<ExpandoObject>.BatchSize

DataFlowBatchDestination<ExpandoObject>.UseBufferBlock

DataFlowBatchDestination<ExpandoObject>.CleanUpOnSuccess()

DataFlowBatchDestination<ExpandoObject>.CleanUpOnFaulted(Exception)

DataFlowBatchDestination<ExpandoObject>.InitComponent()

DataFlowBatchDestination<ExpandoObject>.WriteBatch(ExpandoObject[])

DataFlowDestination<ExpandoObject>.TargetBlock

DataFlowDestination<ExpandoObject>.TargetAction

DataFlowDestination<ExpandoObject>.Buffer

DataFlowDestination<ExpandoObject>.BufferTargetAction

DataFlowDestination<ExpandoObject>.InternalBatchSize

DataFlowDestination<ExpandoObject>.DEFAULT_BATCH_SIZE

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.InitCheckedParameter()

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 CosmosDestination : CosmosDestination<ExpandoObject>, IDataFlowBatchDestination<ExpandoObject>, IDataFlowDestination<ExpandoObject>, IDataFlowBatchDestination, IDataFlowDestination, IDataFlowComponent, ILoggableTask

Constructors

CosmosDestination()

Declaration

    public CosmosDestination()

CosmosDestination(int)

Declaration

    public CosmosDestination(int batchSize)

Parameters

Type	Name	Description
int	batchSize

CosmosDestination(string, string, string)

Declaration

    public CosmosDestination(string connectionString, string databaseName, string containerName)

Parameters

Type	Name	Description
string	connectionString
string	databaseName
string	containerName

Implements

IDataFlowBatchDestination<TInput>

IDataFlowDestination<TInput>

IDataFlowBatchDestination

IDataFlowDestination

IDataFlowComponent