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

Class ArrowFlightJdbcBinaryVectorAccessor

java.lang.Object

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

org.apache.arrow.driver.jdbc.accessor.impl.binary.ArrowFlightJdbcBinaryVectorAccessor

All Implemented Interfaces:

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

public class ArrowFlightJdbcBinaryVectorAccessor
extends ArrowFlightJdbcAccessor

Accessor for the Arrow types: FixedSizeBinaryVector, VarBinaryVector and LargeVarBinaryVector.

Field Summary

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

wasNull, wasNullConsumer

Constructor Summary

Constructors

Constructor	Description
ArrowFlightJdbcBinaryVectorAccessor(FixedSizeBinaryVector vector, IntSupplier currentRowSupplier, ArrowFlightJdbcAccessorFactory.WasNullConsumer setCursorWasNull)
ArrowFlightJdbcBinaryVectorAccessor(LargeVarBinaryVector vector, IntSupplier currentRowSupplier, ArrowFlightJdbcAccessorFactory.WasNullConsumer setCursorWasNull)
ArrowFlightJdbcBinaryVectorAccessor(VarBinaryVector vector, IntSupplier currentRowSupplier, ArrowFlightJdbcAccessorFactory.WasNullConsumer setCursorWasNull)

Method Summary

Modifier and Type	Method	Description
InputStream	getAsciiStream()
InputStream	getBinaryStream()
byte[]	getBytes()
Reader	getCharacterStream()
Object	getObject()
Class<?>	getObjectClass()
String	getString()
InputStream	getUnicodeStream()

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

getArray, getBigDecimal, getBigDecimal, getBlob, getBoolean, getByte, getClob, getCurrentRow, getDate, getDouble, getFloat, getInt, getLong, getNCharacterStream, getNClob, getNString, getObject, getObject, getRef, getShort, getSQLXML, getStruct, getTime, getTimestamp, getURL, wasNull

Methods inherited from class java.lang.Object

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

Constructor Details

ArrowFlightJdbcBinaryVectorAccessor

public ArrowFlightJdbcBinaryVectorAccessor(FixedSizeBinaryVector vector,
 IntSupplier currentRowSupplier,
 ArrowFlightJdbcAccessorFactory.WasNullConsumer setCursorWasNull)

ArrowFlightJdbcBinaryVectorAccessor

public ArrowFlightJdbcBinaryVectorAccessor(VarBinaryVector vector,
 IntSupplier currentRowSupplier,
 ArrowFlightJdbcAccessorFactory.WasNullConsumer setCursorWasNull)

ArrowFlightJdbcBinaryVectorAccessor

public ArrowFlightJdbcBinaryVectorAccessor(LargeVarBinaryVector vector,
 IntSupplier currentRowSupplier,
 ArrowFlightJdbcAccessorFactory.WasNullConsumer setCursorWasNull)

Method Details

getBytes

public byte[] getBytes()

Specified by:

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

Overrides:

getBytes in class ArrowFlightJdbcAccessor

getObject

public Object getObject()

Specified by:

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

Overrides:

getObject in class ArrowFlightJdbcAccessor

getObjectClass

public Class<?> getObjectClass()

Specified by:

getObjectClass in class ArrowFlightJdbcAccessor

getString

public String getString()

Specified by:

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

Overrides:

getString in class ArrowFlightJdbcAccessor

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

getBinaryStream

public InputStream getBinaryStream()

Specified by:

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

Overrides:

getBinaryStream in class ArrowFlightJdbcAccessor

getCharacterStream

public Reader getCharacterStream()

Specified by:

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

Overrides:

getCharacterStream in class ArrowFlightJdbcAccessor