Interface IRawUploadQueue<T>

Interface to CDF Raw upload queues. The items in the queue are DTOs (data type objects) of type T.

Inherited Members

IUploadQueue<(string key, T columns)>.Enqueue((string key, T columns))

IUploadQueue<(string key, T columns)>.Enqueue(IEnumerable<(string key, T columns)>)

IUploadQueue<(string key, T columns)>.Dequeue()

IUploadQueue<(string key, T columns)>.Trigger(CancellationToken)

IUploadQueue.Start(CancellationToken)

IDisposable.Dispose()

IAsyncDisposable.DisposeAsync()

Namespace: Cognite.Extractor.Utils

Assembly: ExtractorUtils.dll

Syntax

public interface IRawUploadQueue<T> : IUploadQueue<(string key, T columns)>, IUploadQueue, IDisposable, IAsyncDisposable

Type Parameters

Name	Description
T

Methods

EnqueueRow(string, T)

Enqueue the DTO of type T to be uploaded as a row to CDF Raw.

Declaration

void EnqueueRow(string key, T columns)

Parameters

Type	Name	Description
string	key	The row key
T	columns	The row columns

Extension Methods

DataModelUtils.GetOrCreateResourcesAsync<T, T2>(T2, IEnumerable<InstanceIdentifier>, Func<IEnumerable<InstanceIdentifier>, IEnumerable<SourcedNodeWrite<T>>>, Func<IEnumerable<SourcedNodeWrite<T>>, SanitationMode, (IEnumerable<SourcedNodeWrite<T>>, IEnumerable<CogniteError<SourcedNodeWrite<T>>>)>, int, int, RetryMode, SanitationMode, CancellationToken)