Package org.apache.arrow.driver.jdbc.accessor.impl.text

Class ArrowFlightJdbcVarCharVectorAccessor

java.lang.Object

org.apache.arrow.driver.jdbc.accessor.ArrowFlightJdbcAccessor

org.apache.arrow.driver.jdbc.accessor.impl.text.ArrowFlightJdbcVarCharVectorAccessor

All Implemented Interfaces:

org.apache.calcite.avatica.util.Cursor.Accessor

public class ArrowFlightJdbcVarCharVectorAccessor
extends ArrowFlightJdbcAccessor

Accessor for the Arrow types: VarCharVector and LargeVarCharVector.

Field Summary

Fields inherited from class org.apache.arrow.driver.jdbc.accessor.ArrowFlightJdbcAccessor

wasNull, wasNullConsumer

Constructor Summary

Constructors

Constructor	Description
ArrowFlightJdbcVarCharVectorAccessor(LargeVarCharVector vector, IntSupplier currentRowSupplier, ArrowFlightJdbcAccessorFactory.WasNullConsumer setCursorWasNull)
ArrowFlightJdbcVarCharVectorAccessor(VarCharVector vector, IntSupplier currentRowSupplier, ArrowFlightJdbcAccessorFactory.WasNullConsumer setCursorWasNull)

Method Summary

Modifier and Type	Method	Description
InputStream	getAsciiStream()
BigDecimal	getBigDecimal()
BigDecimal	getBigDecimal(int i)
boolean	getBoolean()
byte	getByte()
byte[]	getBytes()
Reader	getCharacterStream()
Date	getDate(Calendar calendar)
double	getDouble()
float	getFloat()
int	getInt()
long	getLong()
String	getObject()
Class<?>	getObjectClass()
short	getShort()
String	getString()
Time	getTime(Calendar calendar)
Timestamp	getTimestamp(Calendar calendar)
InputStream	getUnicodeStream()

Methods inherited from class org.apache.arrow.driver.jdbc.accessor.ArrowFlightJdbcAccessor

getArray, getBinaryStream, getBlob, getClob, getCurrentRow, getNCharacterStream, getNClob, getNString, getObject, getObject, getRef, getSQLXML, getStruct, getURL, wasNull

Methods inherited from class java.lang.Object

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

Constructor Details

ArrowFlightJdbcVarCharVectorAccessor

public ArrowFlightJdbcVarCharVectorAccessor(VarCharVector vector,
 IntSupplier currentRowSupplier,
 ArrowFlightJdbcAccessorFactory.WasNullConsumer setCursorWasNull)

ArrowFlightJdbcVarCharVectorAccessor

public ArrowFlightJdbcVarCharVectorAccessor(LargeVarCharVector vector,
 IntSupplier currentRowSupplier,
 ArrowFlightJdbcAccessorFactory.WasNullConsumer setCursorWasNull)

Method Details

getObjectClass

public Class<?> getObjectClass()

Specified by:

getObjectClass in class ArrowFlightJdbcAccessor

getObject

public String getObject()

Specified by:

getObject in interface org.apache.calcite.avatica.util.Cursor.Accessor

Overrides:

getObject in class ArrowFlightJdbcAccessor

getString

public String getString()

Specified by:

getString in interface org.apache.calcite.avatica.util.Cursor.Accessor

Overrides:

getString in class ArrowFlightJdbcAccessor

getBytes

public byte[] getBytes()

Specified by:

getBytes in interface org.apache.calcite.avatica.util.Cursor.Accessor

Overrides:

getBytes in class ArrowFlightJdbcAccessor

getBoolean

public boolean getBoolean()
                   throws SQLException

Specified by:

getBoolean in interface org.apache.calcite.avatica.util.Cursor.Accessor

Overrides:

getBoolean in class ArrowFlightJdbcAccessor

Throws:

SQLException

getByte

public byte getByte()
             throws SQLException

Specified by:

getByte in interface org.apache.calcite.avatica.util.Cursor.Accessor

Overrides:

getByte in class ArrowFlightJdbcAccessor

Throws:

SQLException

getShort

public short getShort()
               throws SQLException

Specified by:

getShort in interface org.apache.calcite.avatica.util.Cursor.Accessor

Overrides:

getShort in class ArrowFlightJdbcAccessor

Throws:

SQLException

getInt

public int getInt()
           throws SQLException

Specified by:

getInt in interface org.apache.calcite.avatica.util.Cursor.Accessor

Overrides:

getInt in class ArrowFlightJdbcAccessor

Throws:

SQLException

getLong

public long getLong()
             throws SQLException

Specified by:

getLong in interface org.apache.calcite.avatica.util.Cursor.Accessor

Overrides:

getLong in class ArrowFlightJdbcAccessor

Throws:

SQLException

getFloat

public float getFloat()
               throws SQLException

Specified by:

getFloat in interface org.apache.calcite.avatica.util.Cursor.Accessor

Overrides:

getFloat in class ArrowFlightJdbcAccessor

Throws:

SQLException

getDouble

public double getDouble()
                 throws SQLException

Specified by:

getDouble in interface org.apache.calcite.avatica.util.Cursor.Accessor

Overrides:

getDouble in class ArrowFlightJdbcAccessor

Throws:

SQLException

getBigDecimal

public BigDecimal getBigDecimal()
                         throws SQLException

Specified by:

getBigDecimal in interface org.apache.calcite.avatica.util.Cursor.Accessor

Overrides:

getBigDecimal in class ArrowFlightJdbcAccessor

Throws:

SQLException

getBigDecimal

public BigDecimal getBigDecimal(int i)
                         throws SQLException

Specified by:

getBigDecimal in interface org.apache.calcite.avatica.util.Cursor.Accessor

Overrides:

getBigDecimal in class ArrowFlightJdbcAccessor

Throws:

SQLException

getAsciiStream

public InputStream getAsciiStream()

Specified by:

getAsciiStream in interface org.apache.calcite.avatica.util.Cursor.Accessor

Overrides:

getAsciiStream in class ArrowFlightJdbcAccessor

getUnicodeStream

public InputStream getUnicodeStream()

Specified by:

getUnicodeStream in interface org.apache.calcite.avatica.util.Cursor.Accessor

Overrides:

getUnicodeStream in class ArrowFlightJdbcAccessor

getCharacterStream

public Reader getCharacterStream()

Specified by:

getCharacterStream in interface org.apache.calcite.avatica.util.Cursor.Accessor

Overrides:

getCharacterStream in class ArrowFlightJdbcAccessor

getDate

public Date getDate(Calendar calendar)
             throws SQLException

Specified by:

getDate in interface org.apache.calcite.avatica.util.Cursor.Accessor

Overrides:

getDate in class ArrowFlightJdbcAccessor

Throws:

SQLException

getTime

public Time getTime(Calendar calendar)
             throws SQLException

Specified by:

getTime in interface org.apache.calcite.avatica.util.Cursor.Accessor

Overrides:

getTime in class ArrowFlightJdbcAccessor

Throws:

SQLException

getTimestamp

public Timestamp getTimestamp(Calendar calendar)
                       throws SQLException

Specified by:

getTimestamp in interface org.apache.calcite.avatica.util.Cursor.Accessor

Overrides:

getTimestamp in class ArrowFlightJdbcAccessor

Throws:

SQLException