Package com.clickhouse.client.api.data_formats.internal

Class AbstractBinaryFormatReader

java.lang.Object

com.clickhouse.client.api.data_formats.internal.AbstractBinaryFormatReader

All Implemented Interfaces:

ClickHouseBinaryFormatReader, ClickHouseFormatReader, AutoCloseable

Direct Known Subclasses:

NativeFormatReader, RowBinaryFormatReader, RowBinaryWithNamesAndTypesFormatReader, RowBinaryWithNamesFormatReader

public abstract class AbstractBinaryFormatReader
extends Object
implements ClickHouseBinaryFormatReader

Field Summary

Fields

Modifier and Type	Field	Description
protected BinaryStreamReader	binaryStreamReader
protected Object[]	currentRecord
protected DataTypeConverter	dataTypeConverter
protected InputStream	input
protected Object[]	nextRecord
protected boolean	nextRecordEmpty
static final Map<ClickHouseDataType,Class<?>>	NO_TYPE_HINT_MAPPING

Constructor Summary

Constructors

Modifier	Constructor	Description
protected	AbstractBinaryFormatReader(InputStream inputStream, QuerySettings querySettings, TableSchema schema, BinaryStreamReader.ByteBufferAllocator byteBufferAllocator, Map<ClickHouseDataType,Class<?>> defaultTypeHintMap)

Method Summary

Modifier and Type	Method	Description
void	close()
protected void	endReached()
BigDecimal	getBigDecimal(int index)	Reads column with name `colName` as a BigDecimal.
BigDecimal	getBigDecimal(String colName)	Reads column with name `colName` as a BigDecimal.
BigInteger	getBigInteger(int index)	Reads column with name `colName` as a BigInteger.
BigInteger	getBigInteger(String colName)	Reads column with name `colName` as a BigInteger.
boolean	getBoolean(int index)	Reads column with name `colName` as a boolean.
boolean	getBoolean(String colName)	Reads column with name `colName` as a boolean.
boolean[]	getBooleanArray(int index)	Returns the value of the specified column as a boolean[].
boolean[]	getBooleanArray(String colName)
byte	getByte(int index)	Reads column with name `colName` as a byte.
byte	getByte(String colName)	Reads column with name `colName` as a byte.
byte[]	getByteArray(int index)	Returns the value of the specified column as a byte[].
byte[]	getByteArray(String colName)
ClickHouseBitmap	getClickHouseBitmap(int index)
ClickHouseBitmap	getClickHouseBitmap(String colName)
Map[]	getConvertions()
double	getDouble(int index)	Reads column with name `colName` as a double.
double	getDouble(String colName)	Reads column with name `colName` as a double.
double[]	getDoubleArray(int index)	Returns the value of the specified column as a double[].
double[]	getDoubleArray(String colName)
Duration	getDuration(int index)	Returns the value of the specified column as a Duration.
Duration	getDuration(String colName)	Returns the value of the specified column as a Duration.
short	getEnum16(int index)
short	getEnum16(String colName)
byte	getEnum8(int index)
byte	getEnum8(String colName)
float	getFloat(int index)	Reads column with name `colName` as a float.
float	getFloat(String colName)	Reads column with name `colName` as a float.
float[]	getFloatArray(int index)	Returns the value of the specified column as a float[].
float[]	getFloatArray(String colName)
ClickHouseGeoMultiPolygonValue	getGeoMultiPolygon(int index)	Returns the value of the specified column as a ClickHouseGeoMultiPolygonValue.
ClickHouseGeoMultiPolygonValue	getGeoMultiPolygon(String colName)	Returns the value of the specified column as a ClickHouseGeoMultiPolygonValue.
ClickHouseGeoPointValue	getGeoPoint(int index)	Returns the value of the specified column as a ClickHouseGeoPointValue.
ClickHouseGeoPointValue	getGeoPoint(String colName)	Returns the value of the specified column as a ClickHouseGeoPointValue.
ClickHouseGeoPolygonValue	getGeoPolygon(int index)	Returns the value of the specified column as a ClickHouseGeoPolygonValue.
ClickHouseGeoPolygonValue	getGeoPolygon(String colName)	Returns the value of the specified column as a ClickHouseGeoPolygonValue.
ClickHouseGeoRingValue	getGeoRing(int index)	Returns the value of the specified column as a ClickHouseGeoRingValue.
ClickHouseGeoRingValue	getGeoRing(String colName)	Returns the value of the specified column as a ClickHouseGeoRingValue.
Inet4Address	getInet4Address(int index)	Returns the value of the specified column as an Inet4Address.
Inet4Address	getInet4Address(String colName)	Returns the value of the specified column as an Inet4Address.
Inet6Address	getInet6Address(int index)	Returns the value of the specified column as an Inet6Address.
Inet6Address	getInet6Address(String colName)	Returns the value of the specified column as an Inet6Address.
Instant	getInstant(int index)	Returns the value of the specified column as an Instant.
Instant	getInstant(String colName)	Returns the value of the specified column as an Instant.
int[]	getIntArray(int index)	Returns the value of the specified column as an int[].
int[]	getIntArray(String colName)
int	getInteger(int index)	Reads column with name `colName` as an integer.
int	getInteger(String colName)	Reads column with name `colName` as an integer.
<T> List<T>	getList(int index)	Returns the value of the specified column as a List.
<T> List<T>	getList(String colName)
LocalDate	getLocalDate(int index)
LocalDate	getLocalDate(String colName)
LocalDateTime	getLocalDateTime(int index)
LocalDateTime	getLocalDateTime(String colName)
LocalTime	getLocalTime(int index)
LocalTime	getLocalTime(String colName)
long	getLong(int index)	Reads column with name `colName` as a long.
long	getLong(String colName)	Reads column with name `colName` as a long.
long[]	getLongArray(int index)	Returns the value of the specified column as a long[].
long[]	getLongArray(String colName)
Object[]	getObjectArray(int index)	Returns the value of the specified column as an Object[].
Object[]	getObjectArray(String colName)
OffsetDateTime	getOffsetDateTime(int index)
OffsetDateTime	getOffsetDateTime(String colName)
TableSchema	getSchema()
short	getShort(int index)	Reads column with name `colName` as a short.
short	getShort(String colName)	Reads column with name `colName` as a short.
short[]	getShortArray(int index)	Returns the value of the specified column as a short[].
short[]	getShortArray(String colName)
String	getString(int index)	Reads column with name `colName` as a string.
String	getString(String colName)	Reads column with name `colName` as a string.
String[]	getStringArray(int index)	Returns the value of the specified column as a String[].
String[]	getStringArray(String colName)
TemporalAmount	getTemporalAmount(int index)
TemporalAmount	getTemporalAmount(String colName)
Object[]	getTuple(int index)
Object[]	getTuple(String colName)
UUID	getUUID(int index)	Returns the value of the specified column as a UUID.
UUID	getUUID(String colName)	Returns the value of the specified column as a UUID.
ZonedDateTime	getZonedDateTime(int index)	Returns the value of the specified column as a ZonedDateTime.
ZonedDateTime	getZonedDateTime(String colName)	Returns the value of the specified column as a ZonedDateTime.
boolean	hasNext()	Checks if there are more rows to read.
boolean	hasValue(int colIndex)
boolean	hasValue(String colName)
Map<String,Object>	next()	Moves cursor to the next row.
protected void	readNextRecord()
protected boolean	readRecord(Object[] record)
boolean	readRecord(Map<String,Object> record)	It is still internal method and should be used with care.
boolean	readToPOJO(Map<String,POJOFieldDeserializer> deserializers, Object obj)	Reads next record into POJO object using set of serializers.
<T> T	readValue(int colIndex)	Reads a single value from the stream.
<T> T	readValue(String colName)	Reads a row to an array of objects.
protected void	setSchema(TableSchema schema)
static byte[]	stringLikeToBytes(Object value)	Converts a string-like value into its raw bytes.

Methods inherited from class java.lang.Object

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

Field Details

NO_TYPE_HINT_MAPPING

public static final Map<ClickHouseDataType,Class<?>> NO_TYPE_HINT_MAPPING

input

protected InputStream input

binaryStreamReader

protected BinaryStreamReader binaryStreamReader

dataTypeConverter

protected DataTypeConverter dataTypeConverter

currentRecord

protected Object[] currentRecord

nextRecord

protected Object[] nextRecord

nextRecordEmpty

protected boolean nextRecordEmpty

Constructor Details

AbstractBinaryFormatReader

protected AbstractBinaryFormatReader(InputStream inputStream,
 QuerySettings querySettings,
 TableSchema schema,
 BinaryStreamReader.ByteBufferAllocator byteBufferAllocator,
 Map<ClickHouseDataType,Class<?>> defaultTypeHintMap)

Method Details

readToPOJO

public boolean readToPOJO(Map<String,POJOFieldDeserializer> deserializers,
 Object obj)
                   throws IOException

Reads next record into POJO object using set of serializers. There should be a serializer for each column in the record, otherwise it will silently skip a field It is done in such a way because it is not the reader concern. Calling code should validate this. Note: internal API

Parameters:

deserializers -

obj -

Returns:

Throws:

IOException

readRecord

public boolean readRecord(Map<String,Object> record)
                   throws IOException

It is still internal method and should be used with care. Usually this method is called to read next record into internal object and affects hasNext() method. So after calling this one: - hasNext(), next() and get methods cannot be called - stream should be read with readRecord() method fully

Parameters:

record -

Returns:

Throws:

IOException

readRecord

protected boolean readRecord(Object[] record)
                      throws IOException

Throws:

IOException

readValue

public <T> T readValue(int colIndex)

Description copied from interface: ClickHouseFormatReader

Reads a single value from the stream.

Specified by:

readValue in interface ClickHouseFormatReader

Returns:

readValue

public <T> T readValue(String colName)

Description copied from interface: ClickHouseFormatReader

Reads a row to an array of objects.

Specified by:

readValue in interface ClickHouseFormatReader

Returns:

hasNext

public boolean hasNext()

Description copied from interface: ClickHouseFormatReader

Checks if there are more rows to read.

Specified by:

hasNext in interface ClickHouseFormatReader

Returns:

readNextRecord

protected void readNextRecord()

next

public Map<String,Object> next()

Description copied from interface: ClickHouseFormatReader

Moves cursor to the next row. Must be called before reading the first row. Returns reference to an internal record representation. It means that next call to the method will affect value in returned Map. This is done for memory usage optimization. Method is intended to be used only by the client not an application.

Specified by:

next in interface ClickHouseFormatReader

Returns:

reference to a map filled with column values or null if no more records are available

endReached

protected void endReached()

setSchema

protected void setSchema(TableSchema schema)

getConvertions

public Map[] getConvertions()

getSchema

public TableSchema getSchema()

Specified by:

getSchema in interface ClickHouseFormatReader

getString

public String getString(String colName)

Description copied from interface: ClickHouseFormatReader

Reads column with name `colName` as a string.

Specified by:

getString in interface ClickHouseFormatReader

Parameters:

colName - - column name

Returns:

getString

public String getString(int index)

Description copied from interface: ClickHouseFormatReader

Reads column with name `colName` as a string.

Specified by:

getString in interface ClickHouseFormatReader

Returns:

getByte

public byte getByte(String colName)

Description copied from interface: ClickHouseFormatReader

Reads column with name `colName` as a byte.

Specified by:

getByte in interface ClickHouseFormatReader

Parameters:

colName - - column name

Returns:

getShort

public short getShort(String colName)

Description copied from interface: ClickHouseFormatReader

Reads column with name `colName` as a short.

Specified by:

getShort in interface ClickHouseFormatReader

Parameters:

colName - - column name

Returns:

getInteger

public int getInteger(String colName)

Description copied from interface: ClickHouseFormatReader

Reads column with name `colName` as an integer.

Specified by:

getInteger in interface ClickHouseFormatReader

Parameters:

colName - - column name

Returns:

getLong

public long getLong(String colName)

Description copied from interface: ClickHouseFormatReader

Reads column with name `colName` as a long.

Specified by:

getLong in interface ClickHouseFormatReader

Parameters:

colName - - column name

Returns:

getFloat

public float getFloat(String colName)

Description copied from interface: ClickHouseFormatReader

Reads column with name `colName` as a float. Warning: this method may lose precision for float values.

Specified by:

getFloat in interface ClickHouseFormatReader

Returns:

getDouble

public double getDouble(String colName)

Description copied from interface: ClickHouseFormatReader

Reads column with name `colName` as a double. Warning: this method may lose precision for double values.

Specified by:

getDouble in interface ClickHouseFormatReader

Returns:

getBoolean

public boolean getBoolean(String colName)

Description copied from interface: ClickHouseFormatReader

Reads column with name `colName` as a boolean.

Specified by:

getBoolean in interface ClickHouseFormatReader

Returns:

getBigInteger

public BigInteger getBigInteger(String colName)

Description copied from interface: ClickHouseFormatReader

Reads column with name `colName` as a BigInteger.

Specified by:

getBigInteger in interface ClickHouseFormatReader

Returns:

getBigDecimal

public BigDecimal getBigDecimal(String colName)

Description copied from interface: ClickHouseFormatReader

Reads column with name `colName` as a BigDecimal.

Specified by:

getBigDecimal in interface ClickHouseFormatReader

Returns:

getInstant

public Instant getInstant(String colName)

Description copied from interface: ClickHouseFormatReader

Returns the value of the specified column as an Instant. Timezone is derived from the column definition. If no timezone is specified in the column definition then UTC will be used. If column value is Date or Date32 it will return an Instant with time set to 00:00:00. If column value is DateTime or DateTime32 it will return an Instant with the time part.

Specified by:

getInstant in interface ClickHouseFormatReader

Returns:

getZonedDateTime

public ZonedDateTime getZonedDateTime(String colName)

Description copied from interface: ClickHouseFormatReader

Returns the value of the specified column as a ZonedDateTime. Timezone is derived from the column definition. If no timezone is specified in the column definition then UTC will be used. If column value is Date or Date32 it will return a ZonedDateTime with time set to 00:00:00. If column value is DateTime or DateTime32 it will return a ZonedDateTime with the time part.

Specified by:

getZonedDateTime in interface ClickHouseFormatReader

Returns:

getDuration

public Duration getDuration(String colName)

Description copied from interface: ClickHouseFormatReader

Returns the value of the specified column as a Duration. If a stored value is bigger than Long.MAX_VALUE then exception will be thrown. In such case use asBigInteger() method. If value of IntervalQuarter then Duration will be in the unit of Months.

Specified by:

getDuration in interface ClickHouseFormatReader

Returns:

Duration in the unit of column type.

getTemporalAmount

public TemporalAmount getTemporalAmount(String colName)

Specified by:

getTemporalAmount in interface ClickHouseFormatReader

getInet4Address

public Inet4Address getInet4Address(String colName)

Description copied from interface: ClickHouseFormatReader

Returns the value of the specified column as an Inet4Address.

Specified by:

getInet4Address in interface ClickHouseFormatReader

Returns:

getInet6Address

public Inet6Address getInet6Address(String colName)

Description copied from interface: ClickHouseFormatReader

Returns the value of the specified column as an Inet6Address.

Specified by:

getInet6Address in interface ClickHouseFormatReader

Returns:

getUUID

public UUID getUUID(String colName)

Description copied from interface: ClickHouseFormatReader

Returns the value of the specified column as a UUID.

Specified by:

getUUID in interface ClickHouseFormatReader

Returns:

getGeoPoint

public ClickHouseGeoPointValue getGeoPoint(String colName)

Description copied from interface: ClickHouseFormatReader

Returns the value of the specified column as a ClickHouseGeoPointValue.

Specified by:

getGeoPoint in interface ClickHouseFormatReader

Returns:

getGeoRing

public ClickHouseGeoRingValue getGeoRing(String colName)

Description copied from interface: ClickHouseFormatReader

Returns the value of the specified column as a ClickHouseGeoRingValue.

Specified by:

getGeoRing in interface ClickHouseFormatReader

Returns:

getGeoPolygon

public ClickHouseGeoPolygonValue getGeoPolygon(String colName)

Description copied from interface: ClickHouseFormatReader

Returns the value of the specified column as a ClickHouseGeoPolygonValue.

Specified by:

getGeoPolygon in interface ClickHouseFormatReader

Returns:

getGeoMultiPolygon

public ClickHouseGeoMultiPolygonValue getGeoMultiPolygon(String colName)

Description copied from interface: ClickHouseFormatReader

Returns the value of the specified column as a ClickHouseGeoMultiPolygonValue.

Specified by:

getGeoMultiPolygon in interface ClickHouseFormatReader

Returns:

getList

public <T> List<T> getList(String colName)

Specified by:

getList in interface ClickHouseFormatReader

Parameters:

colName - - column name

Returns:

list of values, or null if the value is null

See Also:

• ClickHouseFormatReader.getList(int)

getByteArray

public byte[] getByteArray(String colName)

Specified by:

getByteArray in interface ClickHouseFormatReader

Parameters:

colName - - column name

Returns:

array of bytes, or null if the value is null

See Also:

• ClickHouseFormatReader.getByteArray(int)

getIntArray

public int[] getIntArray(String colName)

Specified by:

getIntArray in interface ClickHouseFormatReader

Parameters:

colName - - column name

Returns:

array of int values, or null if the value is null

See Also:

• ClickHouseFormatReader.getIntArray(int)

getLongArray

public long[] getLongArray(String colName)

Specified by:

getLongArray in interface ClickHouseFormatReader

Parameters:

colName - - column name

Returns:

array of long values, or null if the value is null

See Also:

• ClickHouseFormatReader.getLongArray(int)

getFloatArray

public float[] getFloatArray(String colName)

Specified by:

getFloatArray in interface ClickHouseFormatReader

Parameters:

colName - - column name

Returns:

array of float values, or null if the value is null

See Also:

• ClickHouseFormatReader.getFloatArray(int)

getDoubleArray

public double[] getDoubleArray(String colName)

Specified by:

getDoubleArray in interface ClickHouseFormatReader

Parameters:

colName - - column name

Returns:

array of double values, or null if the value is null

See Also:

• ClickHouseFormatReader.getDoubleArray(int)

getBooleanArray

public boolean[] getBooleanArray(String colName)

Specified by:

getBooleanArray in interface ClickHouseFormatReader

Parameters:

colName - - column name

Returns:

array of boolean values, or null if the value is null

See Also:

• ClickHouseFormatReader.getBooleanArray(int)

getShortArray

public short[] getShortArray(String colName)

Specified by:

getShortArray in interface ClickHouseFormatReader

Parameters:

colName - - column name

Returns:

array of short values, or null if the value is null

See Also:

• ClickHouseFormatReader.getShortArray(int)

getStringArray

public String[] getStringArray(String colName)

Specified by:

getStringArray in interface ClickHouseFormatReader

Parameters:

colName - - column name

Returns:

array of string values, or null if the value is null

See Also:

• ClickHouseFormatReader.getStringArray(int)

getObjectArray

public Object[] getObjectArray(String colName)

Specified by:

getObjectArray in interface ClickHouseFormatReader

Parameters:

colName - - column name

Returns:

array of objects, or null if the value is null

See Also:

• ClickHouseFormatReader.getObjectArray(int)

hasValue

public boolean hasValue(int colIndex)

Specified by:

hasValue in interface ClickHouseFormatReader

hasValue

public boolean hasValue(String colName)

Specified by:

hasValue in interface ClickHouseFormatReader

getByte

public byte getByte(int index)

Description copied from interface: ClickHouseFormatReader

Reads column with name `colName` as a byte.

Specified by:

getByte in interface ClickHouseFormatReader

Returns:

getShort

public short getShort(int index)

Description copied from interface: ClickHouseFormatReader

Reads column with name `colName` as a short.

Specified by:

getShort in interface ClickHouseFormatReader

Returns:

getInteger

public int getInteger(int index)

Description copied from interface: ClickHouseFormatReader

Reads column with name `colName` as an integer.

Specified by:

getInteger in interface ClickHouseFormatReader

Returns:

getLong

public long getLong(int index)

Description copied from interface: ClickHouseFormatReader

Reads column with name `colName` as a long.

Specified by:

getLong in interface ClickHouseFormatReader

Returns:

getFloat

public float getFloat(int index)

Description copied from interface: ClickHouseFormatReader

Reads column with name `colName` as a float. Warning: this method may lose precision for float values.

Specified by:

getFloat in interface ClickHouseFormatReader

Returns:

getDouble

public double getDouble(int index)

Description copied from interface: ClickHouseFormatReader

Reads column with name `colName` as a double. Warning: this method may lose precision for double values.

Specified by:

getDouble in interface ClickHouseFormatReader

Returns:

getBoolean

public boolean getBoolean(int index)

Description copied from interface: ClickHouseFormatReader

Reads column with name `colName` as a boolean.

Specified by:

getBoolean in interface ClickHouseFormatReader

Returns:

getBigInteger

public BigInteger getBigInteger(int index)

Description copied from interface: ClickHouseFormatReader

Reads column with name `colName` as a BigInteger.

Specified by:

getBigInteger in interface ClickHouseFormatReader

Returns:

getBigDecimal

public BigDecimal getBigDecimal(int index)

Description copied from interface: ClickHouseFormatReader

Reads column with name `colName` as a BigDecimal.

Specified by:

getBigDecimal in interface ClickHouseFormatReader

Returns:

getInstant

public Instant getInstant(int index)

Description copied from interface: ClickHouseFormatReader

Returns the value of the specified column as an Instant. Timezone is derived from the column definition. If no timezone is specified in the column definition then UTC will be used. If column value is Date or Date32 it will return an Instant with time set to 00:00:00. If column value is DateTime or DateTime32 it will return an Instant with the time part.

Specified by:

getInstant in interface ClickHouseFormatReader

Returns:

stringLikeToBytes

public static byte[] stringLikeToBytes(Object value)

Converts a string-like value into its raw bytes. For a StringValue the original bytes are returned without re-encoding (so binary content is preserved). For a String the bytes are produced using UTF-8, matching the historical behaviour. Returns null when the value is not a string-like type so callers can fall back to other handling.

Parameters:

value - value to convert

Returns:

raw bytes or null if the value is not string-like

getZonedDateTime

public ZonedDateTime getZonedDateTime(int index)

Description copied from interface: ClickHouseFormatReader

Returns the value of the specified column as a ZonedDateTime. Timezone is derived from the column definition. If no timezone is specified in the column definition then UTC will be used. If column value is Date or Date32 it will return a ZonedDateTime with time set to 00:00:00. If column value is DateTime or DateTime32 it will return a ZonedDateTime with the time part.

Specified by:

getZonedDateTime in interface ClickHouseFormatReader

Returns:

getDuration

public Duration getDuration(int index)

Description copied from interface: ClickHouseFormatReader

Returns the value of the specified column as a Duration. If a stored value is bigger than Long.MAX_VALUE then exception will be thrown. In such case use asBigInteger() method. If value of IntervalQuarter then Duration will be in the unit of Months.

Specified by:

getDuration in interface ClickHouseFormatReader

Returns:

Duration in the unit of column type.

getTemporalAmount

public TemporalAmount getTemporalAmount(int index)

Specified by:

getTemporalAmount in interface ClickHouseFormatReader

getInet4Address

public Inet4Address getInet4Address(int index)

Description copied from interface: ClickHouseFormatReader

Returns the value of the specified column as an Inet4Address.

Specified by:

getInet4Address in interface ClickHouseFormatReader

Returns:

getInet6Address

public Inet6Address getInet6Address(int index)

Description copied from interface: ClickHouseFormatReader

Returns the value of the specified column as an Inet6Address.

Specified by:

getInet6Address in interface ClickHouseFormatReader

Returns:

getUUID

public UUID getUUID(int index)

Description copied from interface: ClickHouseFormatReader

Returns the value of the specified column as a UUID.

Specified by:

getUUID in interface ClickHouseFormatReader

Returns:

getGeoPoint

public ClickHouseGeoPointValue getGeoPoint(int index)

Description copied from interface: ClickHouseFormatReader

Returns the value of the specified column as a ClickHouseGeoPointValue.

Specified by:

getGeoPoint in interface ClickHouseFormatReader

Returns:

getGeoRing

public ClickHouseGeoRingValue getGeoRing(int index)

Description copied from interface: ClickHouseFormatReader

Returns the value of the specified column as a ClickHouseGeoRingValue.

Specified by:

getGeoRing in interface ClickHouseFormatReader

Returns:

getGeoPolygon

public ClickHouseGeoPolygonValue getGeoPolygon(int index)

Description copied from interface: ClickHouseFormatReader

Returns the value of the specified column as a ClickHouseGeoPolygonValue.

Specified by:

getGeoPolygon in interface ClickHouseFormatReader

Returns:

getGeoMultiPolygon

public ClickHouseGeoMultiPolygonValue getGeoMultiPolygon(int index)

Description copied from interface: ClickHouseFormatReader

Returns the value of the specified column as a ClickHouseGeoMultiPolygonValue.

Specified by:

getGeoMultiPolygon in interface ClickHouseFormatReader

Returns:

getList

public <T> List<T> getList(int index)

Description copied from interface: ClickHouseFormatReader

Returns the value of the specified column as a List. Suitable for reading Array columns of any type.

For nested arrays (e.g. Array(Array(Int64))), returns a List<List<Long>>. For nullable arrays (e.g. Array(Nullable(Int32))), list elements may be null.

Specified by:

getList in interface ClickHouseFormatReader

Parameters:

index - - column index (1-based)

Returns:

list of values, or null if the value is null

getByteArray

public byte[] getByteArray(int index)

Description copied from interface: ClickHouseFormatReader

Returns the value of the specified column as a byte[]. Suitable for 1D Array columns only.

Specified by:

getByteArray in interface ClickHouseFormatReader

Parameters:

index - - column index (1-based)

Returns:

array of bytes, or null if the value is null

getIntArray

public int[] getIntArray(int index)

Description copied from interface: ClickHouseFormatReader

Returns the value of the specified column as an int[]. Suitable for 1D Array columns only.

Specified by:

getIntArray in interface ClickHouseFormatReader

Parameters:

index - - column index (1-based)

Returns:

array of int values, or null if the value is null

getLongArray

public long[] getLongArray(int index)

Description copied from interface: ClickHouseFormatReader

Returns the value of the specified column as a long[]. Suitable for 1D Array columns only.

Specified by:

getLongArray in interface ClickHouseFormatReader

Parameters:

index - - column index (1-based)

Returns:

array of long values, or null if the value is null

getFloatArray

public float[] getFloatArray(int index)

Description copied from interface: ClickHouseFormatReader

Returns the value of the specified column as a float[]. Suitable for 1D Array columns only.

Specified by:

getFloatArray in interface ClickHouseFormatReader

Parameters:

index - - column index (1-based)

Returns:

array of float values, or null if the value is null

getDoubleArray

public double[] getDoubleArray(int index)

Description copied from interface: ClickHouseFormatReader

Returns the value of the specified column as a double[]. Suitable for 1D Array columns only.

Specified by:

getDoubleArray in interface ClickHouseFormatReader

Parameters:

index - - column index (1-based)

Returns:

array of double values, or null if the value is null

getBooleanArray

public boolean[] getBooleanArray(int index)

Description copied from interface: ClickHouseFormatReader

Returns the value of the specified column as a boolean[]. Suitable for 1D Array columns only.

Specified by:

getBooleanArray in interface ClickHouseFormatReader

Parameters:

index - - column index (1-based)

Returns:

array of boolean values, or null if the value is null

getShortArray

public short[] getShortArray(int index)

Description copied from interface: ClickHouseFormatReader

Returns the value of the specified column as a short[]. Suitable for 1D Array columns only.

Specified by:

getShortArray in interface ClickHouseFormatReader

Parameters:

index - - column index (1-based)

Returns:

array of short values, or null if the value is null

getStringArray

public String[] getStringArray(int index)

Description copied from interface: ClickHouseFormatReader

Returns the value of the specified column as a String[]. Suitable for 1D Array columns only. Cannot be used for none string element types.

Specified by:

getStringArray in interface ClickHouseFormatReader

Parameters:

index - - column index (1-based)

Returns:

array of string values, or null if the value is null

getObjectArray

public Object[] getObjectArray(int index)

Description copied from interface: ClickHouseFormatReader

Returns the value of the specified column as an Object[]. Suitable for multidimensional Array columns. Nested arrays are recursively converted to Object[]. Note: result is not cached so avoid repetitive calls on same column.

Specified by:

getObjectArray in interface ClickHouseFormatReader

Parameters:

index - - column index (1-based)

Returns:

array of objects, or null if the value is null

getTuple

public Object[] getTuple(int index)

Specified by:

getTuple in interface ClickHouseFormatReader

getTuple

public Object[] getTuple(String colName)

Specified by:

getTuple in interface ClickHouseFormatReader

getEnum8

public byte getEnum8(String colName)

Specified by:

getEnum8 in interface ClickHouseFormatReader

getEnum8

public byte getEnum8(int index)

Specified by:

getEnum8 in interface ClickHouseFormatReader

getEnum16

public short getEnum16(String colName)

Specified by:

getEnum16 in interface ClickHouseFormatReader

getEnum16

public short getEnum16(int index)

Specified by:

getEnum16 in interface ClickHouseFormatReader

getLocalDate

public LocalDate getLocalDate(String colName)

Specified by:

getLocalDate in interface ClickHouseFormatReader

getLocalDate

public LocalDate getLocalDate(int index)

Specified by:

getLocalDate in interface ClickHouseFormatReader

getLocalTime

public LocalTime getLocalTime(String colName)

Specified by:

getLocalTime in interface ClickHouseFormatReader

getLocalTime

public LocalTime getLocalTime(int index)

Specified by:

getLocalTime in interface ClickHouseFormatReader

getLocalDateTime

public LocalDateTime getLocalDateTime(String colName)

Specified by:

getLocalDateTime in interface ClickHouseFormatReader

getLocalDateTime

public LocalDateTime getLocalDateTime(int index)

Specified by:

getLocalDateTime in interface ClickHouseFormatReader

getOffsetDateTime

public OffsetDateTime getOffsetDateTime(String colName)

Specified by:

getOffsetDateTime in interface ClickHouseFormatReader

getOffsetDateTime

public OffsetDateTime getOffsetDateTime(int index)

Specified by:

getOffsetDateTime in interface ClickHouseFormatReader

getClickHouseBitmap

public ClickHouseBitmap getClickHouseBitmap(String colName)

Specified by:

getClickHouseBitmap in interface ClickHouseFormatReader

getClickHouseBitmap

public ClickHouseBitmap getClickHouseBitmap(int index)

Specified by:

getClickHouseBitmap in interface ClickHouseFormatReader

close

public void close()
           throws Exception

Specified by:

close in interface AutoCloseable

Throws:

Exception