com.microsoft.azure.kusto.ingest

Class IngestClientBase

java.lang.Object

com.microsoft.azure.kusto.ingest.IngestClientBase

All Implemented Interfaces:

IngestClient, Closeable, AutoCloseable

Direct Known Subclasses:

ManagedStreamingIngestClient, QueuedIngestClientImpl, StreamingIngestClient

public abstract class IngestClientBase
extends Object
implements IngestClient

Constructor Summary

Constructors

Constructor and Description
IngestClientBase()

Method Summary

Modifier and Type	Method and Description
protected abstract String	getClientType()
protected Map<String,String>	getIngestionTraceAttributes(TraceableAttributes sourceInfo, TraceableAttributes ingestionProperties)
IngestionResult	ingestFromBlob(BlobSourceInfo blobSourceInfo, IngestionProperties ingestionProperties) Ingest data from a blob storage into Kusto database.
reactor.core.publisher.Mono<IngestionResult>	ingestFromBlobAsync(BlobSourceInfo blobSourceInfo, IngestionProperties ingestionProperties) Ingest data from a blob storage into Kusto table.
protected abstract reactor.core.publisher.Mono<IngestionResult>	ingestFromBlobAsyncImpl(BlobSourceInfo blobSourceInfo, IngestionProperties ingestionProperties)
IngestionResult	ingestFromFile(FileSourceInfo fileSourceInfo, IngestionProperties ingestionProperties) Ingest data from a file into Kusto table.
reactor.core.publisher.Mono<IngestionResult>	ingestFromFileAsync(FileSourceInfo fileSourceInfo, IngestionProperties ingestionProperties) Ingest data from a file into Kusto table.
protected abstract reactor.core.publisher.Mono<IngestionResult>	ingestFromFileAsyncImpl(FileSourceInfo fileSourceInfo, IngestionProperties ingestionProperties)
IngestionResult	ingestFromResultSet(ResultSetSourceInfo resultSetSourceInfo, IngestionProperties ingestionProperties) Ingest data from a Result Set into Kusto database.
reactor.core.publisher.Mono<IngestionResult>	ingestFromResultSetAsync(ResultSetSourceInfo resultSetSourceInfo, IngestionProperties ingestionProperties) Ingest data from a Result Set into Kusto table.
protected abstract reactor.core.publisher.Mono<IngestionResult>	ingestFromResultSetAsyncImpl(ResultSetSourceInfo resultSetSourceInfo, IngestionProperties ingestionProperties)
IngestionResult	ingestFromStream(StreamSourceInfo streamSourceInfo, IngestionProperties ingestionProperties) Ingest data from an input stream, into Kusto database.
reactor.core.publisher.Mono<IngestionResult>	ingestFromStreamAsync(StreamSourceInfo streamSourceInfo, IngestionProperties ingestionProperties) Ingest data from an input stream, into Kusto table.
protected abstract reactor.core.publisher.Mono<IngestionResult>	ingestFromStreamAsyncImpl(StreamSourceInfo streamSourceInfo, IngestionProperties ingestionProperties)

Methods inherited from class java.lang.Object

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

Methods inherited from interface java.io.Closeable

close

Constructor Detail

IngestClientBase

public IngestClientBase()

Method Detail

ingestFromFile

public IngestionResult ingestFromFile(FileSourceInfo fileSourceInfo,
                                      IngestionProperties ingestionProperties)

Description copied from interface: IngestClient

Ingest data from a file into Kusto table.

This method ingests the data from a given file, described in fileSourceInfo, into Kusto table, according to the properties mentioned in ingestionProperties

Specified by:

ingestFromFile in interface IngestClient

Parameters:

fileSourceInfo - The specific SourceInfo to be ingested

ingestionProperties - Settings used to customize the ingestion operation

Returns:

IngestionResult object including the ingestion result

See Also:

FileSourceInfo, IngestionProperties

ingestFromFileAsyncImpl

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

ingestFromFileAsync

public reactor.core.publisher.Mono<IngestionResult> ingestFromFileAsync(FileSourceInfo fileSourceInfo,
                                                                        IngestionProperties ingestionProperties)

Description copied from interface: IngestClient

Ingest data from a file into Kusto table.

This method ingests the data from a given file, described in fileSourceInfo, into Kusto table, according to the properties mentioned in ingestionProperties

Specified by:

ingestFromFileAsync in interface IngestClient

Parameters:

fileSourceInfo - The specific SourceInfo to be ingested

ingestionProperties - Settings used to customize the ingestion operation

Returns:

IngestionResult object including the ingestion result

See Also:

FileSourceInfo, IngestionProperties

ingestFromBlob

public IngestionResult ingestFromBlob(BlobSourceInfo blobSourceInfo,
                                      IngestionProperties ingestionProperties)

Ingest data from a blob storage into Kusto database.

This method ingests the data from a given blob, described in blobSourceInfo, into Kusto database, according to the properties mentioned in ingestionProperties

Specified by:

ingestFromBlob in interface IngestClient

Parameters:

blobSourceInfo - The specific SourceInfo to be ingested

ingestionProperties - Settings used to customize the ingestion operation

Returns:

IngestionResult object including the ingestion result

See Also:

BlobSourceInfo, IngestionProperties

ingestFromBlobAsyncImpl

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

ingestFromBlobAsync

public reactor.core.publisher.Mono<IngestionResult> ingestFromBlobAsync(BlobSourceInfo blobSourceInfo,
                                                                        IngestionProperties ingestionProperties)

Description copied from interface: IngestClient

Ingest data from a blob storage into Kusto table.

This method ingests the data from a given blob, described in blobSourceInfo, into Kusto table, according to the properties mentioned in ingestionProperties

Specified by:

ingestFromBlobAsync in interface IngestClient

Parameters:

blobSourceInfo - The specific SourceInfo to be ingested

ingestionProperties - Settings used to customize the ingestion operation

Returns:

IngestionResult object including the ingestion result

See Also:

BlobSourceInfo, IngestionProperties

ingestFromResultSet

public IngestionResult ingestFromResultSet(ResultSetSourceInfo resultSetSourceInfo,
                                           IngestionProperties ingestionProperties)

Ingest data from a Result Set into Kusto database.

This method ingests the data from a given Result Set, described in resultSetSourceInfo, into Kusto database, according to the properties mentioned in ingestionProperties

Ingesting from ResultSet is equivalent to ingesting from a csv stream. The DataFormat should be empty or set to "csv", and the mapping, should it be provided, should be csv mapping.

Specified by:

ingestFromResultSet in interface IngestClient

Parameters:

resultSetSourceInfo - The specific SourceInfo to be ingested

ingestionProperties - Settings used to customize the ingestion operation

Returns:

IngestionResult object including the ingestion result

See Also:

ResultSetSourceInfo, IngestionProperties

ingestFromResultSetAsyncImpl

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

ingestFromResultSetAsync

public reactor.core.publisher.Mono<IngestionResult> ingestFromResultSetAsync(ResultSetSourceInfo resultSetSourceInfo,
                                                                             IngestionProperties ingestionProperties)

Description copied from interface: IngestClient

Ingest data from a Result Set into Kusto table.

This method ingests the data from a given Result Set, described in resultSetSourceInfo, into Kusto table, according to the properties mentioned in ingestionProperties

Ingesting from ResultSet is equivalent to ingesting from a csv stream. The DataFormat should be empty or set to "csv", and the mapping, should it be provided, should be csv mapping.

Specified by:

ingestFromResultSetAsync in interface IngestClient

Parameters:

resultSetSourceInfo - The specific SourceInfo to be ingested

ingestionProperties - Settings used to customize the ingestion operation

Returns:

IngestionResult object including the ingestion result

See Also:

ResultSetSourceInfo, IngestionProperties

ingestFromStream

public IngestionResult ingestFromStream(StreamSourceInfo streamSourceInfo,
                                        IngestionProperties ingestionProperties)

Ingest data from an input stream, into Kusto database.

This method ingests the data from a given input stream, described in streamSourceInfo, into Kusto database, according to the properties mentioned in ingestionProperties

Specified by:

ingestFromStream in interface IngestClient

Parameters:

streamSourceInfo - The specific SourceInfo to be ingested

ingestionProperties - Settings used to customize the ingestion operation

Returns:

IngestionResult object including the ingestion result

See Also:

StreamSourceInfo, IngestionProperties

ingestFromStreamAsyncImpl

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

ingestFromStreamAsync

public reactor.core.publisher.Mono<IngestionResult> ingestFromStreamAsync(StreamSourceInfo streamSourceInfo,
                                                                          IngestionProperties ingestionProperties)

Description copied from interface: IngestClient

Ingest data from an input stream, into Kusto table.

This method ingests the data from a given input stream, described in streamSourceInfo, into Kusto table, according to the properties mentioned in ingestionProperties

Specified by:

ingestFromStreamAsync in interface IngestClient

Parameters:

streamSourceInfo - The specific SourceInfo to be ingested

ingestionProperties - Settings used to customize the ingestion operation

Returns:

IngestionResult object including the ingestion result

See Also:

StreamSourceInfo, IngestionProperties

getIngestionTraceAttributes

protected Map<String,String> getIngestionTraceAttributes(TraceableAttributes sourceInfo,
                                                         TraceableAttributes ingestionProperties)

getClientType

protected abstract String getClientType()