Uses of Class
com.clickhouse.client.ClickHouseInputStream
-
Packages that use ClickHouseInputStream Package Description com.clickhouse.client Provides necessary classes to communicate with ClickHouse server.com.clickhouse.client.data Provides necessary classes to handle different format or type of data.com.clickhouse.client.stream -
-
Uses of ClickHouseInputStream in com.clickhouse.client
Fields in com.clickhouse.client declared as ClickHouseInputStream Modifier and Type Field Description protected ClickHouseInputStreamClickHouseDataProcessor. inputFields in com.clickhouse.client with type parameters of type ClickHouseInputStream Modifier and Type Field Description protected ClickHouseDeferredValue<ClickHouseInputStream>ClickHouseRequest. inputMethods in com.clickhouse.client that return ClickHouseInputStream Modifier and Type Method Description ClickHouseInputStreamClickHouseFile. asInputStream()Creates an input stream for reading the file.static ClickHouseInputStreamClickHouseInputStream. empty()Gets an empty input stream that produces nothing and cannot be closed.static ClickHouseInputStreamClickHouseClient. getAsyncResponseInputStream(ClickHouseConfig config, InputStream input, Runnable postCloseAction)Gets piped input stream for reading data from response asynchronously.ClickHouseInputStreamClickHousePipedOutputStream. getInput()Deprecated.will be removed in v0.3.3, please useClickHousePipedOutputStream.getInputStream()insteadClickHouseInputStreamClickHousePipedOutputStream. getInputStream()Gets input stream to reada data being written into the output stream.abstract ClickHouseInputStreamClickHousePipedOutputStream. getInputStream(Runnable postCloseAction)Gets input stream to reada data being written into the output stream.ClickHouseInputStreamClickHouseResponse. getInputStream()Gets input stream of the response.static ClickHouseInputStreamClickHouseClient. getResponseInputStream(ClickHouseConfig config, InputStream input, Runnable postCloseAction)Gets wrapped input stream for reading data from response.static ClickHouseInputStreamClickHouseInputStream. of(byte[]... bytes)Wraps the given byte arrays.static ClickHouseInputStreamClickHouseInputStream. of(ClickHouseDeferredValue<InputStream> deferredInput, int bufferSize, Runnable postCloseAction)Wraps the deferred input stream.static ClickHouseInputStreamClickHouseInputStream. of(ClickHouseFile file, int bufferSize, Runnable postCloseAction)Wraps the given file as input stream.static ClickHouseInputStreamClickHouseInputStream. of(File... files)Wraps the given files.static ClickHouseInputStreamClickHouseInputStream. of(InputStream... inputs)Wraps the given input streams.static ClickHouseInputStreamClickHouseInputStream. of(InputStream input, int bufferSize)Wraps the given input stream.static ClickHouseInputStreamClickHouseInputStream. of(InputStream input, int bufferSize, ClickHouseCompression compression)Wraps the given input stream.static ClickHouseInputStreamClickHouseInputStream. of(InputStream input, int bufferSize, ClickHouseCompression compression, Runnable postCloseAction)Wraps the given input stream.static ClickHouseInputStreamClickHouseInputStream. of(InputStream input, int bufferSize, Runnable postCloseAction)Wraps the given input stream.static <T> ClickHouseInputStreamClickHouseInputStream. of(Iterable<T> source, Class<T> clazz, Function<T,byte[]> converter, Runnable postCloseAction)Wraps the given iterable objects as byte array based binary input stream.static ClickHouseInputStreamClickHouseInputStream. of(String... strings)Wraps the given (UTF-8)strings.static ClickHouseInputStreamClickHouseInputStream. of(URL... urls)Wraps the given URLs.static ClickHouseInputStreamClickHouseInputStream. of(ByteBuffer... buffers)Wraps the given byte buffers.static ClickHouseInputStreamClickHouseInputStream. of(BlockingQueue<ByteBuffer> queue, int timeout)Wraps the given blocking queue.static ClickHouseInputStreamClickHouseInputStream. of(BlockingQueue<ByteBuffer> queue, int timeout, Runnable postCloseAction)Wraps the given blocking queue.static <T> ClickHouseInputStreamClickHouseInputStream. of(T[] source, Class<T> clazz, Function<T,byte[]> converter, Runnable postCloseAction)Wraps the given array of object as byte array based binary input stream.static ClickHouseInputStreamClickHouseInputStream. wrap(ClickHouseFile file, InputStream input, int bufferSize, Runnable postCloseAction, ClickHouseCompression compression, int compressionLevel)Wraps the given input stream.Methods in com.clickhouse.client that return types with arguments of type ClickHouseInputStream Modifier and Type Method Description Optional<ClickHouseInputStream>ClickHouseRequest. getInputStream()Gets input stream.Methods in com.clickhouse.client with parameters of type ClickHouseInputStream Modifier and Type Method Description ClickHouseRequest.MutationClickHouseRequest.Mutation. data(ClickHouseInputStream input)Loads data from input stream.TClickHouseDeserializer. deserialize(T ref, ClickHouseConfig config, ClickHouseColumn column, ClickHouseInputStream input)Deserializes data read from input stream.ClickHouseDataProcessorClickHouseDataStreamFactory. getProcessor(ClickHouseConfig config, ClickHouseInputStream input, ClickHouseOutputStream output, Map<String,Object> settings, List<ClickHouseColumn> columns)Gets data processor according to givenClickHouseConfigand settings.Method parameters in com.clickhouse.client with type arguments of type ClickHouseInputStream Modifier and Type Method Description ClickHouseRequest.MutationClickHouseRequest.Mutation. data(ClickHouseDeferredValue<ClickHouseInputStream> input)Loads data from input stream.Constructors in com.clickhouse.client with parameters of type ClickHouseInputStream Constructor Description ClickHouseDataProcessor(ClickHouseConfig config, ClickHouseInputStream input, ClickHouseOutputStream output, List<ClickHouseColumn> columns, Map<String,Object> settings)Default constructor. -
Uses of ClickHouseInputStream in com.clickhouse.client.data
Fields in com.clickhouse.client.data declared as ClickHouseInputStream Modifier and Type Field Description protected ClickHouseInputStreamClickHouseStreamResponse. inputMethods in com.clickhouse.client.data that return ClickHouseInputStream Modifier and Type Method Description ClickHouseInputStreamClickHousePipedStream. getInputStream(Runnable postCloseAction)Deprecated.ClickHouseInputStreamClickHouseSimpleResponse. getInputStream()ClickHouseInputStreamClickHouseStreamResponse. getInputStream()Methods in com.clickhouse.client.data with parameters of type ClickHouseInputStream Modifier and Type Method Description ClickHouseValueClickHouseRowBinaryProcessor.MappedFunctions. deserialize(ClickHouseValue ref, ClickHouseConfig config, ClickHouseColumn column, ClickHouseInputStream input)ClickHouseValueClickHouseTabSeparatedProcessor.MappedFunctions. deserialize(ClickHouseValue ref, ClickHouseConfig config, ClickHouseColumn column, ClickHouseInputStream input)Deserializes data read from input stream.static ClickHouseResponseClickHouseStreamResponse. of(ClickHouseConfig config, ClickHouseInputStream input)static ClickHouseResponseClickHouseStreamResponse. of(ClickHouseConfig config, ClickHouseInputStream input, List<ClickHouseColumn> columns)static ClickHouseResponseClickHouseStreamResponse. of(ClickHouseConfig config, ClickHouseInputStream input, Map<String,Object> settings)static ClickHouseResponseClickHouseStreamResponse. of(ClickHouseConfig config, ClickHouseInputStream input, Map<String,Object> settings, List<ClickHouseColumn> columns)static ClickHouseResponseClickHouseStreamResponse. of(ClickHouseConfig config, ClickHouseInputStream input, Map<String,Object> settings, List<ClickHouseColumn> columns, ClickHouseResponseSummary summary)static ClickHouseBitmapBinaryStreamUtils. readBitmap(ClickHouseInputStream input, ClickHouseDataType dataType)Reads bitmap from given input stream.static booleanBinaryStreamUtils. readBoolean(ClickHouseInputStream input)Read boolean from given input stream.static LocalDateBinaryStreamUtils. readDate(ClickHouseInputStream input)ReadLocalDatefrom given input stream.static LocalDateBinaryStreamUtils. readDate(ClickHouseInputStream input, TimeZone tz)ReadLocalDatefrom given input stream.static LocalDateBinaryStreamUtils. readDate32(ClickHouseInputStream input)ReadLocalDatefrom given input stream.static LocalDateBinaryStreamUtils. readDate32(ClickHouseInputStream input, TimeZone tz)ReadLocalDatefrom given input stream.static LocalDateTimeBinaryStreamUtils. readDateTime(ClickHouseInputStream input, int scale, TimeZone tz)ReadLocalDateTimefrom given input stream.static LocalDateTimeBinaryStreamUtils. readDateTime(ClickHouseInputStream input, TimeZone tz)ReadLocalDateTimefrom given input stream.static LocalDateTimeBinaryStreamUtils. readDateTime32(ClickHouseInputStream input, TimeZone tz)ReadLocalDateTimefrom given input stream.static LocalDateTimeBinaryStreamUtils. readDateTime64(ClickHouseInputStream input, int scale, TimeZone tz)ReadLocalDateTimefrom given input stream.static LocalDateTimeBinaryStreamUtils. readDateTime64(ClickHouseInputStream input, TimeZone tz)ReadLocalDateTimefrom given input stream.static BigDecimalBinaryStreamUtils. readDecimal(ClickHouseInputStream input, int precision, int scale)Read big decimal(4 - 32 bytes) from given input stream.static BigDecimalBinaryStreamUtils. readDecimal128(ClickHouseInputStream input, int scale)Read big decimal(16 bytes) from given input stream.static BigDecimalBinaryStreamUtils. readDecimal256(ClickHouseInputStream input, int scale)Read big decimal from given input stream.static BigDecimalBinaryStreamUtils. readDecimal32(ClickHouseInputStream input, int scale)Read big decimal(4 bytes) from given input stream.static BigDecimalBinaryStreamUtils. readDecimal64(ClickHouseInputStream input, int scale)Read big decimal(8 bytes) from gicen input stream.static shortBinaryStreamUtils. readEnum16(ClickHouseInputStream input)Read enum value from given input stream.static <T extends Enum<T>>
TBinaryStreamUtils. readEnum16(ClickHouseInputStream input, Class<T> enumType)Read enum value from given input stream.static byteBinaryStreamUtils. readEnum8(ClickHouseInputStream input)Read enum value from given input stream.static <T extends Enum<T>>
TBinaryStreamUtils. readEnum8(ClickHouseInputStream input, Class<T> enumType)Read enum value from given input stream.static StringBinaryStreamUtils. readFixedString(ClickHouseInputStream input, int length)Read string with fixed length from given input stream.static StringBinaryStreamUtils. readFixedString(ClickHouseInputStream input, int length, Charset charset)Read string with fixed length from given input stream.static floatBinaryStreamUtils. readFloat32(ClickHouseInputStream input)Read a float value from given input stream.static doubleBinaryStreamUtils. readFloat64(ClickHouseInputStream input)Read a double value from given input stream.static double[][][][]BinaryStreamUtils. readGeoMultiPolygon(ClickHouseInputStream input)Read geo multi-polygon(array of polygons) from given input stream.static double[]BinaryStreamUtils. readGeoPoint(ClickHouseInputStream input)Read geo point(X and Y coordinates) from given input stream.static double[][][]BinaryStreamUtils. readGeoPolygon(ClickHouseInputStream input)Read geo polygon(array of rings) from given input stream.static double[][]BinaryStreamUtils. readGeoRing(ClickHouseInputStream input)Read geo ring(array of X and Y coordinates) from given input stream.static Inet4AddressBinaryStreamUtils. readInet4Address(ClickHouseInputStream input)Read Inet4Address from given input stream.static Inet6AddressBinaryStreamUtils. readInet6Address(ClickHouseInputStream input)Read Inet6Address from given input stream.static BigIntegerBinaryStreamUtils. readInt128(ClickHouseInputStream input)Read a big integer(16 bytes) from given input stream.static shortBinaryStreamUtils. readInt16(ClickHouseInputStream input)Read a short value from given input stream.static BigIntegerBinaryStreamUtils. readInt256(ClickHouseInputStream input)Read a big integer(32 bytes) from given input stream.static intBinaryStreamUtils. readInt32(ClickHouseInputStream input)Read an integer from given input stream.static longBinaryStreamUtils. readInt64(ClickHouseInputStream input)Read a long value from given input stream.static byteBinaryStreamUtils. readInt8(ClickHouseInputStream input)Read a byte from given input stream.static booleanBinaryStreamUtils. readNull(ClickHouseInputStream input)Read null marker from input stream.static BigIntegerBinaryStreamUtils. readUnsignedInt128(ClickHouseInputStream input)Read an unsigned big integer from given input stream.static intBinaryStreamUtils. readUnsignedInt16(ClickHouseInputStream input)Read an unsigned short value from given input stream.static BigIntegerBinaryStreamUtils. readUnsignedInt256(ClickHouseInputStream input)Read an unsigned big integer(32 bytes) from given input stream.static longBinaryStreamUtils. readUnsignedInt32(ClickHouseInputStream input)Read an unsigned integer from given input stream.static BigIntegerBinaryStreamUtils. readUnsignedInt64(ClickHouseInputStream input)Read an unsigned long value from given input stream.static shortBinaryStreamUtils. readUnsignedInt8(ClickHouseInputStream input)Read an unsigned byte as short from given input stream.static UUIDBinaryStreamUtils. readUuid(ClickHouseInputStream input)Read UUID from given input stream.Constructors in com.clickhouse.client.data with parameters of type ClickHouseInputStream Constructor Description ClickHouseRowBinaryProcessor(ClickHouseConfig config, ClickHouseInputStream input, ClickHouseOutputStream output, List<ClickHouseColumn> columns, Map<String,Object> settings)Default constructor.ClickHouseStreamResponse(ClickHouseConfig config, ClickHouseInputStream input, Map<String,Object> settings, List<ClickHouseColumn> columns, ClickHouseResponseSummary summary)ClickHouseTabSeparatedProcessor(ClickHouseConfig config, ClickHouseInputStream input, ClickHouseOutputStream output, List<ClickHouseColumn> columns, Map<String,Object> settings) -
Uses of ClickHouseInputStream in com.clickhouse.client.stream
Subclasses of ClickHouseInputStream in com.clickhouse.client.stream Modifier and Type Class Description classAbstractByteArrayInputStreamByte-array backed input stream.classAbstractByteBufferInputStreamByteBufferbacked input stream.classBlockingInputStreamByteBufferbacked input stream withBlockingQueue.classEmptyInputStreamEmpty input stream produces nothing and it can never be closed.classIterableByteArrayInputStreamclassIterableByteBufferInputStreamclassIterableMultipleInputStream<T>classIterableObjectInputStream<T>classLz4InputStreamReader from clickhouse in lz4.classNonBlockingInputStreamclassWrappedInputStreamWrapper ofInputStreamwith buffer.Methods in com.clickhouse.client.stream that return ClickHouseInputStream Modifier and Type Method Description ClickHouseInputStreamBlockingPipedOutputStream. getInputStream(Runnable postCloseAction)ClickHouseInputStreamNonBlockingPipedOutputStream. getInputStream(Runnable postCloseAction)
-