Package org.apache.arrow.driver.jdbc

Class ArrowFlightJdbcVectorSchemaRootResultSet

java.lang.Object
org.apache.calcite.avatica.util.ArrayFactoryImpl
org.apache.calcite.avatica.AvaticaResultSet
org.apache.arrow.driver.jdbc.ArrowFlightJdbcVectorSchemaRootResultSet
All Implemented Interfaces:
AutoCloseable, ResultSet, Wrapper, org.apache.calcite.avatica.util.ArrayImpl.Factory
Direct Known Subclasses:
ArrowFlightJdbcFlightStreamResultSet
public class ArrowFlightJdbcVectorSchemaRootResultSet extends org.apache.calcite.avatica.AvaticaResultSet
ResultSet implementation used to access a VectorSchemaRoot.

  • Field Summary

    Fields inherited from class org.apache.calcite.avatica.AvaticaResultSet

    accessorList, columnMetaDataList, cursor, firstFrame, localCalendar, resultSetMetaData, signature, state, statement

    Fields inherited from interface java.sql.ResultSet

    CLOSE_CURSORS_AT_COMMIT, CONCUR_READ_ONLY, CONCUR_UPDATABLE, FETCH_FORWARD, FETCH_REVERSE, FETCH_UNKNOWN, HOLD_CURSORS_OVER_COMMIT, TYPE_FORWARD_ONLY, TYPE_SCROLL_INSENSITIVE, TYPE_SCROLL_SENSITIVE

  • Method Summary

    Modifier and Type
    Method
    Description
    protected void
    cancel()
     
    void
    close()
     
    protected org.apache.calcite.avatica.AvaticaResultSet
    execute()
     
    static ArrowFlightJdbcVectorSchemaRootResultSet
    fromVectorSchemaRoot(VectorSchemaRoot vectorSchemaRoot)
    Instantiate a ResultSet backed up by given VectorSchemaRoot.

    Methods inherited from class org.apache.calcite.avatica.AvaticaResultSet

    absolute, afterLast, beforeFirst, cancelRowUpdates, checkOpen, clearWarnings, deleteRow, execute2, findColumn, first, getArray, getArray, getAsciiStream, getAsciiStream, getBigDecimal, getBigDecimal, getBigDecimal, getBigDecimal, getBinaryStream, getBinaryStream, getBlob, getBlob, getBoolean, getBoolean, getByte, getByte, getBytes, getBytes, getCharacterStream, getCharacterStream, getClob, getClob, getConcurrency, getCursorName, getDate, getDate, getDate, getDate, getDouble, getDouble, getFetchDirection, getFetchSize, getFloat, getFloat, getHoldability, getInt, getInt, getLocalCalendar, getLong, getLong, getMetaData, getNCharacterStream, getNCharacterStream, getNClob, getNClob, getNString, getNString, getObject, getObject, getObject, getObject, getObject, getObject, getRef, getRef, getRow, getRowId, getRowId, getShort, getShort, getSQLXML, getSQLXML, getStatement, getString, getString, getTime, getTime, getTime, getTime, getTimestamp, getTimestamp, getTimestamp, getTimestamp, getType, getUnicodeStream, getUnicodeStream, getURL, getURL, getWarnings, insertRow, isAfterLast, isBeforeFirst, isClosed, isFirst, isLast, isWrapperFor, last, moveToCurrentRow, moveToInsertRow, next, previous, refreshRow, relative, rowDeleted, rowInserted, rowUpdated, setFetchDirection, setFetchSize, unwrap, updateArray, updateArray, updateAsciiStream, updateAsciiStream, updateAsciiStream, updateAsciiStream, updateAsciiStream, updateAsciiStream, updateBigDecimal, updateBigDecimal, updateBinaryStream, updateBinaryStream, updateBinaryStream, updateBinaryStream, updateBinaryStream, updateBinaryStream, updateBlob, updateBlob, updateBlob, updateBlob, updateBlob, updateBlob, updateBoolean, updateBoolean, updateByte, updateByte, updateBytes, updateBytes, updateCharacterStream, updateCharacterStream, updateCharacterStream, updateCharacterStream, updateCharacterStream, updateCharacterStream, updateClob, updateClob, updateClob, updateClob, updateClob, updateClob, updateDate, updateDate, updateDouble, updateDouble, updateFloat, updateFloat, updateInt, updateInt, updateLong, updateLong, updateNCharacterStream, updateNCharacterStream, updateNCharacterStream, updateNCharacterStream, updateNClob, updateNClob, updateNClob, updateNClob, updateNClob, updateNClob, updateNString, updateNString, updateNull, updateNull, updateObject, updateObject, updateObject, updateObject, updateRef, updateRef, updateRow, updateRowId, updateRowId, updateShort, updateShort, updateSQLXML, updateSQLXML, updateString, updateString, updateTime, updateTime, updateTimestamp, updateTimestamp, wasNull

    Methods inherited from class org.apache.calcite.avatica.util.ArrayFactoryImpl

    create, createArray

    Methods inherited from class java.lang.Object

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

    Methods inherited from interface java.sql.ResultSet

    updateObject, updateObject, updateObject, updateObject

  • Method Details

    • fromVectorSchemaRoot

      public static ArrowFlightJdbcVectorSchemaRootResultSet fromVectorSchemaRoot(VectorSchemaRoot vectorSchemaRoot) throws SQLException
      Instantiate a ResultSet backed up by given VectorSchemaRoot.
      Parameters:
      vectorSchemaRoot - root from which the ResultSet will access.
      Returns:
      a ResultSet which accesses the given VectorSchemaRoot
      Throws:
      SQLException

    • execute

      protected org.apache.calcite.avatica.AvaticaResultSet execute() throws SQLException
      Overrides:
      execute in class org.apache.calcite.avatica.AvaticaResultSet
      Throws:
      SQLException

    • cancel

      protected void cancel()
      Overrides:
      cancel in class org.apache.calcite.avatica.AvaticaResultSet

    • close

      public void close()
      Specified by:
      close in interface AutoCloseable
      Specified by:
      close in interface ResultSet
      Overrides:
      close in class org.apache.calcite.avatica.AvaticaResultSet