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

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