com.microsoft.azure.kusto.ingest

Class QueuedIngestClientImpl

java.lang.Object

com.microsoft.azure.kusto.ingest.IngestClientBase

com.microsoft.azure.kusto.ingest.QueuedIngestClientImpl

All Implemented Interfaces:

IngestClient, QueuedIngestClient, Closeable, AutoCloseable

public class QueuedIngestClientImpl
extends IngestClientBase
implements QueuedIngestClient

Field Summary

Fields

Modifier and Type	Field and Description
static String	CLASS_NAME

Method Summary

Modifier and Type	Method and Description
void	close()
protected String	getClientType()
IngestionResourceManager	getResourceManager()
protected reactor.core.publisher.Mono<IngestionResult>	ingestFromBlobAsyncImpl(BlobSourceInfo blobSourceInfo, IngestionProperties ingestionProperties)
protected reactor.core.publisher.Mono<IngestionResult>	ingestFromFileAsyncImpl(FileSourceInfo fileSourceInfo, IngestionProperties ingestionProperties)
protected reactor.core.publisher.Mono<IngestionResult>	ingestFromResultSetAsyncImpl(ResultSetSourceInfo resultSetSourceInfo, IngestionProperties ingestionProperties)
protected reactor.core.publisher.Mono<IngestionResult>	ingestFromStreamAsyncImpl(StreamSourceInfo streamSourceInfo, IngestionProperties ingestionProperties)
protected void	setConnectionDataSource(String connectionDataSource)
void	setQueueRequestOptions(com.azure.storage.common.policy.RequestRetryOptions queueRequestOptions) Setter for QueueRequestOptions used by the client on adding ingest message to the Azure queue, read here https://docs.microsoft.com/azure/data-explorer/kusto/api/netfx/about-kusto-ingest#ingest-client-flavors about Kusto queued ingestion

Methods inherited from class com.microsoft.azure.kusto.ingest.IngestClientBase

getIngestionTraceAttributes, ingestFromBlob, ingestFromBlobAsync, ingestFromFile, ingestFromFileAsync, ingestFromResultSet, ingestFromResultSetAsync, ingestFromStream, ingestFromStreamAsync

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Methods inherited from interface com.microsoft.azure.kusto.ingest.IngestClient

ingestFromBlob, ingestFromBlobAsync, ingestFromFile, ingestFromFileAsync, ingestFromResultSet, ingestFromResultSetAsync, ingestFromStream, ingestFromStreamAsync

Field Detail

CLASS_NAME

public static final String CLASS_NAME

Method Detail

setQueueRequestOptions

public void setQueueRequestOptions(com.azure.storage.common.policy.RequestRetryOptions queueRequestOptions)

Description copied from interface: QueuedIngestClient

Setter for QueueRequestOptions used by the client on adding ingest message to the Azure queue, read here https://docs.microsoft.com/azure/data-explorer/kusto/api/netfx/about-kusto-ingest#ingest-client-flavors about Kusto queued ingestion

Specified by:

setQueueRequestOptions in interface QueuedIngestClient

Parameters:

queueRequestOptions - - Options to use when creating QueueClient

getResourceManager

public IngestionResourceManager getResourceManager()

Specified by:

getResourceManager in interface QueuedIngestClient

ingestFromBlobAsyncImpl

protected reactor.core.publisher.Mono<IngestionResult> ingestFromBlobAsyncImpl(BlobSourceInfo blobSourceInfo,
                                                                               IngestionProperties ingestionProperties)

Specified by:

ingestFromBlobAsyncImpl in class IngestClientBase

ingestFromFileAsyncImpl

protected reactor.core.publisher.Mono<IngestionResult> ingestFromFileAsyncImpl(FileSourceInfo fileSourceInfo,
                                                                               IngestionProperties ingestionProperties)

Specified by:

ingestFromFileAsyncImpl in class IngestClientBase

ingestFromStreamAsyncImpl

protected reactor.core.publisher.Mono<IngestionResult> ingestFromStreamAsyncImpl(StreamSourceInfo streamSourceInfo,
                                                                                 IngestionProperties ingestionProperties)

Specified by:

ingestFromStreamAsyncImpl in class IngestClientBase

getClientType

protected String getClientType()

Specified by:

getClientType in class IngestClientBase

ingestFromResultSetAsyncImpl

protected reactor.core.publisher.Mono<IngestionResult> ingestFromResultSetAsyncImpl(ResultSetSourceInfo resultSetSourceInfo,
                                                                                    IngestionProperties ingestionProperties)

Specified by:

ingestFromResultSetAsyncImpl in class IngestClientBase

setConnectionDataSource

protected void setConnectionDataSource(String connectionDataSource)

close

public void close()

Specified by:

close in interface Closeable

Specified by:

close in interface AutoCloseable