com.microsoft.azure.kusto.ingest.utils

Class IngestionUtils

java.lang.Object

com.microsoft.azure.kusto.ingest.utils.IngestionUtils

public class IngestionUtils
extends Object

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static class	IngestionUtils.IntegerHolder

Method Summary

Modifier and Type	Method and Description
static reactor.core.publisher.Mono<ByteArrayInputStream>	compressStream(InputStream uncompressedStream, boolean leaveOpen)
static @NotNull StreamSourceInfo	fileToStream(FileSourceInfo fileSourceInfo, boolean resettable)
static CompressionType	getCompression(String fileName)
static byte[]	readBytesFromInputStream(InputStream inputStream, int bytesToRead)
static @NotNull StreamSourceInfo	resultSetToStream(ResultSetSourceInfo resultSetSourceInfo)
static reactor.core.publisher.Mono<byte[]>	toByteArray(InputStream inputStream) Converts an InputStream to a Mono of byte array.

Methods inherited from class java.lang.Object

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

Method Detail

fileToStream

@NotNull
public static @NotNull StreamSourceInfo fileToStream(FileSourceInfo fileSourceInfo,
                                                              boolean resettable)
                                                       throws IngestionClientException,
                                                              FileNotFoundException

Throws:

IngestionClientException

FileNotFoundException

resultSetToStream

@NotNull
public static @NotNull StreamSourceInfo resultSetToStream(ResultSetSourceInfo resultSetSourceInfo)
                                                            throws IOException,
                                                                   IngestionClientException

Throws:

IOException

IngestionClientException

readBytesFromInputStream

public static byte[] readBytesFromInputStream(InputStream inputStream,
                                              int bytesToRead)
                                       throws IOException

Throws:

IOException

getCompression

public static CompressionType getCompression(String fileName)

compressStream

public static reactor.core.publisher.Mono<ByteArrayInputStream> compressStream(InputStream uncompressedStream,
                                                                               boolean leaveOpen)

toByteArray

public static reactor.core.publisher.Mono<byte[]> toByteArray(InputStream inputStream)

Converts an InputStream to a Mono of byte array.

Parameters:

inputStream - the InputStream to convert

Returns:

a Mono containing the byte array read from the InputStream