Package org.apache.arrow.driver.jdbc

Class ArrowFlightJdbcFlightStreamResultSet

java.lang.Object
org.apache.calcite.avatica.util.ArrayFactoryImpl
org.apache.calcite.avatica.AvaticaResultSet
org.apache.arrow.driver.jdbc.ArrowFlightJdbcVectorSchemaRootResultSet
org.apache.arrow.driver.jdbc.ArrowFlightJdbcFlightStreamResultSet
All Implemented Interfaces:
AutoCloseable, ResultSet, Wrapper, org.apache.calcite.avatica.util.ArrayImpl.Factory
public final class ArrowFlightJdbcFlightStreamResultSet extends ArrowFlightJdbcVectorSchemaRootResultSet
ResultSet implementation for Arrow Flight used to access the results of multiple FlightStream objects.

  • 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()
     
    byte[]
    getAppMetadata()
    Expose appMetadata associated with the underlying FlightInfo for this ResultSet.
    boolean
    next()
     

    Methods inherited from class org.apache.arrow.driver.jdbc.ArrowFlightJdbcVectorSchemaRootResultSet

    fromVectorSchemaRoot

    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, 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