| Package | Description |
|---|---|
| com.microsoft.azure.kusto.ingest | |
| com.microsoft.azure.kusto.ingest.source | |
| com.microsoft.azure.kusto.ingest.utils |
| Modifier and Type | Method and Description |
|---|---|
IngestionResult |
IngestClientBase.ingestFromStream(StreamSourceInfo streamSourceInfo,
IngestionProperties ingestionProperties)
Ingest data from an input stream, into Kusto database.
|
IngestionResult |
IngestClient.ingestFromStream(StreamSourceInfo streamSourceInfo,
IngestionProperties ingestionProperties)
Ingest data from an input stream, into Kusto table.
|
reactor.core.publisher.Mono<IngestionResult> |
IngestClientBase.ingestFromStreamAsync(StreamSourceInfo streamSourceInfo,
IngestionProperties ingestionProperties) |
reactor.core.publisher.Mono<IngestionResult> |
IngestClient.ingestFromStreamAsync(StreamSourceInfo streamSourceInfo,
IngestionProperties ingestionProperties)
Ingest data from an input stream, into Kusto table.
|
protected reactor.core.publisher.Mono<IngestionResult> |
QueuedIngestClientImpl.ingestFromStreamAsyncImpl(StreamSourceInfo streamSourceInfo,
IngestionProperties ingestionProperties) |
protected abstract reactor.core.publisher.Mono<IngestionResult> |
IngestClientBase.ingestFromStreamAsyncImpl(StreamSourceInfo streamSourceInfo,
IngestionProperties ingestionProperties) |
protected reactor.core.publisher.Mono<IngestionResult> |
StreamingIngestClient.ingestFromStreamAsyncImpl(StreamSourceInfo streamSourceInfo,
IngestionProperties ingestionProperties) |
protected reactor.core.publisher.Mono<IngestionResult> |
ManagedStreamingIngestClient.ingestFromStreamAsyncImpl(StreamSourceInfo streamSourceInfo,
IngestionProperties ingestionProperties) |
| Modifier and Type | Method and Description |
|---|---|
static BlobSourceInfo |
BlobSourceInfo.fromStream(String blobPath,
Integer size,
StreamSourceInfo streamSourceInfo) |
| Modifier and Type | Method and Description |
|---|---|
static @NotNull StreamSourceInfo |
IngestionUtils.fileToStream(FileSourceInfo fileSourceInfo,
boolean resettable) |
static @NotNull StreamSourceInfo |
IngestionUtils.resultSetToStream(ResultSetSourceInfo resultSetSourceInfo) |
Copyright © 2025. All rights reserved.