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

Method Detail

execute

protected org.apache.calcite.avatica.AvaticaResultSet execute()
                                                       throws SQLException

Overrides:

execute in class ArrowFlightJdbcVectorSchemaRootResultSet

Throws:

SQLException

getAppMetadata

public byte[] getAppMetadata()

Expose appMetadata associated with the underlying FlightInfo for this ResultSet.

next

public boolean next()
             throws SQLException

Specified by:

next in interface ResultSet

Overrides:

next in class org.apache.calcite.avatica.AvaticaResultSet

Throws:

SQLException

cancel

protected void cancel()

Overrides:

cancel in class ArrowFlightJdbcVectorSchemaRootResultSet

close

public void close()

Specified by:

close in interface AutoCloseable

Specified by:

close in interface ResultSet

Overrides:

close in class ArrowFlightJdbcVectorSchemaRootResultSet