| Package | Description |
|---|---|
| com.microsoft.azure.kusto.ingest | |
| com.microsoft.azure.kusto.ingest.source |
| Modifier and Type | Method and Description |
|---|---|
IngestionResult |
IngestClientBase.ingestFromBlob(BlobSourceInfo blobSourceInfo,
IngestionProperties ingestionProperties)
Ingest data from a blob storage into Kusto database.
|
IngestionResult |
IngestClient.ingestFromBlob(BlobSourceInfo blobSourceInfo,
IngestionProperties ingestionProperties)
Ingest data from a blob storage into Kusto table.
|
reactor.core.publisher.Mono<IngestionResult> |
IngestClientBase.ingestFromBlobAsync(BlobSourceInfo blobSourceInfo,
IngestionProperties ingestionProperties) |
reactor.core.publisher.Mono<IngestionResult> |
IngestClient.ingestFromBlobAsync(BlobSourceInfo blobSourceInfo,
IngestionProperties ingestionProperties)
Ingest data from a blob storage into Kusto table.
|
protected reactor.core.publisher.Mono<IngestionResult> |
QueuedIngestClientImpl.ingestFromBlobAsyncImpl(BlobSourceInfo blobSourceInfo,
IngestionProperties ingestionProperties) |
protected abstract reactor.core.publisher.Mono<IngestionResult> |
IngestClientBase.ingestFromBlobAsyncImpl(BlobSourceInfo blobSourceInfo,
IngestionProperties ingestionProperties) |
protected reactor.core.publisher.Mono<IngestionResult> |
StreamingIngestClient.ingestFromBlobAsyncImpl(BlobSourceInfo blobSourceInfo,
IngestionProperties ingestionProperties) |
protected reactor.core.publisher.Mono<IngestionResult> |
ManagedStreamingIngestClient.ingestFromBlobAsyncImpl(BlobSourceInfo blobSourceInfo,
IngestionProperties ingestionProperties) |
| Modifier and Type | Method and Description |
|---|---|
static BlobSourceInfo |
BlobSourceInfo.fromFile(String blobPath,
FileSourceInfo fileSourceInfo,
CompressionType sourceCompressionType,
boolean gotCompressed) |
static BlobSourceInfo |
BlobSourceInfo.fromStream(String blobPath,
Integer size,
StreamSourceInfo streamSourceInfo) |
Copyright © 2025. All rights reserved.