public class ArrowFlightStatement extends org.apache.calcite.avatica.AvaticaStatement implements ArrowFlightInfoStatement
cancelFlag, closed, closeOnCompletion, connection, DEFAULT_FETCH_SIZE, handle, maxRowCount, openResultSet, updateCountCLOSE_ALL_RESULTS, CLOSE_CURRENT_RESULT, EXECUTE_FAILED, KEEP_CURRENT_RESULT, NO_GENERATED_KEYS, RETURN_GENERATED_KEYS, SUCCESS_NO_INFO| Modifier and Type | Method and Description |
|---|---|
FlightInfo |
executeFlightInfoQuery()
Executes the query this
Statement is holding. |
ArrowFlightConnection |
getConnection() |
addBatch, cancel, checkOpen, clearBatch, clearWarnings, close_, close, closeOnCompletion, execute, execute, execute, execute, executeBatch, executeBatchInternal, executeInternal, executeInternal, executeLargeBatch, executeLargeUpdate, executeQuery, executeQueryInternal, executeUpdate, executeUpdate, executeUpdate, executeUpdate, getBoundParameterValues, getFetchDirection, getFetchSize, getGeneratedKeys, getId, getLargeMaxRows, getLargeUpdateCount, getMaxFieldSize, getMaxRows, getMoreResults, getMoreResults, getParameterValues, getQueryTimeout, getResultSet, getResultSetConcurrency, getResultSetHoldability, getResultSetType, getSignature, getStatementType, getUpdateCount, getWarnings, isClosed, isCloseOnCompletion, isPoolable, isWrapperFor, resetStatement, setCursorName, setEscapeProcessing, setFetchDirection, setFetchSize, setLargeMaxRows, setMaxFieldSize, setMaxRows, setPoolable, setQueryTimeout, setSignature, syncResults, unwrapclone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, waitaddBatch, cancel, clearBatch, clearWarnings, close, closeOnCompletion, execute, execute, execute, execute, executeBatch, executeLargeBatch, executeLargeUpdate, executeLargeUpdate, executeLargeUpdate, executeLargeUpdate, executeQuery, executeUpdate, executeUpdate, executeUpdate, executeUpdate, getFetchDirection, getFetchSize, getGeneratedKeys, getLargeMaxRows, getLargeUpdateCount, getMaxFieldSize, getMaxRows, getMoreResults, getMoreResults, getQueryTimeout, getResultSet, getResultSetConcurrency, getResultSetHoldability, getResultSetType, getUpdateCount, getWarnings, isClosed, isCloseOnCompletion, isPoolable, setCursorName, setEscapeProcessing, setFetchDirection, setFetchSize, setLargeMaxRows, setMaxFieldSize, setMaxRows, setPoolable, setQueryTimeoutisWrapperFor, unwrappublic ArrowFlightConnection getConnection() throws SQLException
getConnection in interface StatementgetConnection in interface ArrowFlightInfoStatementgetConnection in class org.apache.calcite.avatica.AvaticaStatementSQLExceptionpublic FlightInfo executeFlightInfoQuery() throws SQLException
ArrowFlightInfoStatementStatement is holding.executeFlightInfoQuery in interface ArrowFlightInfoStatementFlightInfo for the results.SQLException - on error.Copyright © 2023 The Apache Software Foundation. All rights reserved.