Package com.clickhouse.client.api.data_formats

Class JSONEachRowFormatReader

java.lang.Object

com.clickhouse.client.api.data_formats.JSONEachRowFormatReader

All Implemented Interfaces:

ClickHouseFormatReader, ClickHouseTextFormatReader, AutoCloseable

public class JSONEachRowFormatReader
extends Object
implements ClickHouseTextFormatReader

Constructor Summary

Constructors

Constructor	Description
JSONEachRowFormatReader(JsonParser parser)

Method Summary

Modifier and Type	Method	Description
void	close()
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)
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.
<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.

Methods inherited from class java.lang.Object

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

Constructor Details

JSONEachRowFormatReader

public JSONEachRowFormatReader(JsonParser parser)

Method Details

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:

hasValue

public boolean hasValue(String colName)

Specified by:

hasValue in interface ClickHouseFormatReader

hasValue

public boolean hasValue(int colIndex)

Specified by:

hasValue in interface ClickHouseFormatReader

hasNext

public boolean hasNext()

Description copied from interface: ClickHouseFormatReader

Checks if there are more rows to read.

Specified by:

hasNext in interface ClickHouseFormatReader

Returns:

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

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:

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.

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)

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(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:

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.

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

getSchema

public TableSchema getSchema()

Specified by:

getSchema 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

getTemporalAmount

public TemporalAmount getTemporalAmount(int index)

Specified by:

getTemporalAmount in interface ClickHouseFormatReader

getTemporalAmount

public TemporalAmount getTemporalAmount(String colName)

Specified by:

getTemporalAmount in interface ClickHouseFormatReader

close

public void close()
           throws Exception

Specified by:

close in interface AutoCloseable

Throws:

Exception