org.apache.arrow.driver.jdbc

Class ArrowFlightMetaImpl

java.lang.Object

org.apache.calcite.avatica.MetaImpl

org.apache.arrow.driver.jdbc.ArrowFlightMetaImpl

All Implemented Interfaces:

org.apache.calcite.avatica.Meta

public class ArrowFlightMetaImpl
extends org.apache.calcite.avatica.MetaImpl

Metadata handler for Arrow Flight.

Nested Class Summary

Nested classes/interfaces inherited from class org.apache.calcite.avatica.MetaImpl

org.apache.calcite.avatica.MetaImpl.ColumnNoNulls, org.apache.calcite.avatica.MetaImpl.ColumnNullable, org.apache.calcite.avatica.MetaImpl.ColumnNullableUnknown, org.apache.calcite.avatica.MetaImpl.MetaAttribute, org.apache.calcite.avatica.MetaImpl.MetaBestRowIdentifier, org.apache.calcite.avatica.MetaImpl.MetaCatalog, org.apache.calcite.avatica.MetaImpl.MetaClientInfoProperty, org.apache.calcite.avatica.MetaImpl.MetaColumn, org.apache.calcite.avatica.MetaImpl.MetaColumnPrivilege, org.apache.calcite.avatica.MetaImpl.MetaCrossReference, org.apache.calcite.avatica.MetaImpl.MetaExportedKey, org.apache.calcite.avatica.MetaImpl.MetaFunction, org.apache.calcite.avatica.MetaImpl.MetaFunctionColumn, org.apache.calcite.avatica.MetaImpl.MetaImportedKey, org.apache.calcite.avatica.MetaImpl.MetaIndexInfo, org.apache.calcite.avatica.MetaImpl.MetaPrimaryKey, org.apache.calcite.avatica.MetaImpl.MetaProcedure, org.apache.calcite.avatica.MetaImpl.MetaProcedureColumn, org.apache.calcite.avatica.MetaImpl.MetaPseudoColumn, org.apache.calcite.avatica.MetaImpl.MetaSchema, org.apache.calcite.avatica.MetaImpl.MetaSuperTable, org.apache.calcite.avatica.MetaImpl.MetaSuperType, org.apache.calcite.avatica.MetaImpl.MetaTable, org.apache.calcite.avatica.MetaImpl.MetaTablePrivilege, org.apache.calcite.avatica.MetaImpl.MetaTableType, org.apache.calcite.avatica.MetaImpl.MetaTypeInfo, org.apache.calcite.avatica.MetaImpl.MetaUdt, org.apache.calcite.avatica.MetaImpl.MetaVersionColumn, org.apache.calcite.avatica.MetaImpl.Named

Nested classes/interfaces inherited from interface org.apache.calcite.avatica.Meta

org.apache.calcite.avatica.Meta.ConnectionHandle, org.apache.calcite.avatica.Meta.ConnectionProperties, org.apache.calcite.avatica.Meta.CursorFactory, org.apache.calcite.avatica.Meta.DatabaseProperty, org.apache.calcite.avatica.Meta.ExecuteBatchResult, org.apache.calcite.avatica.Meta.ExecuteResult, org.apache.calcite.avatica.Meta.Factory, org.apache.calcite.avatica.Meta.Frame, org.apache.calcite.avatica.Meta.MetaResultSet, org.apache.calcite.avatica.Meta.Pat, org.apache.calcite.avatica.Meta.PrepareCallback, org.apache.calcite.avatica.Meta.Signature, org.apache.calcite.avatica.Meta.StatementHandle, org.apache.calcite.avatica.Meta.StatementType, org.apache.calcite.avatica.Meta.Style

Field Summary

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

connection, connProps

Constructor Summary

Constructors

Constructor and Description
ArrowFlightMetaImpl(org.apache.calcite.avatica.AvaticaConnection connection) Constructs a MetaImpl object specific for Arrow Flight.

Method Summary

Modifier and Type	Method and Description
void	closeStatement(org.apache.calcite.avatica.Meta.StatementHandle statementHandle)
void	commit(org.apache.calcite.avatica.Meta.ConnectionHandle connectionHandle)
org.apache.calcite.avatica.Meta.ExecuteResult	execute(org.apache.calcite.avatica.Meta.StatementHandle statementHandle, List<org.apache.calcite.avatica.remote.TypedValue> typedValues, int maxRowsInFirstFrame)
org.apache.calcite.avatica.Meta.ExecuteResult	execute(org.apache.calcite.avatica.Meta.StatementHandle statementHandle, List<org.apache.calcite.avatica.remote.TypedValue> typedValues, long maxRowCount)
org.apache.calcite.avatica.Meta.ExecuteBatchResult	executeBatch(org.apache.calcite.avatica.Meta.StatementHandle statementHandle, List<List<org.apache.calcite.avatica.remote.TypedValue>> parameterValuesList)
org.apache.calcite.avatica.Meta.Frame	fetch(org.apache.calcite.avatica.Meta.StatementHandle statementHandle, long offset, int fetchMaxRowCount)
org.apache.calcite.avatica.Meta.StatementHandle	prepare(org.apache.calcite.avatica.Meta.ConnectionHandle connectionHandle, String query, long maxRowCount)
org.apache.calcite.avatica.Meta.ExecuteResult	prepareAndExecute(org.apache.calcite.avatica.Meta.StatementHandle handle, String query, long maxRowCount, int maxRowsInFirstFrame, org.apache.calcite.avatica.Meta.PrepareCallback callback)
org.apache.calcite.avatica.Meta.ExecuteResult	prepareAndExecute(org.apache.calcite.avatica.Meta.StatementHandle statementHandle, String query, long maxRowCount, org.apache.calcite.avatica.Meta.PrepareCallback prepareCallback)
org.apache.calcite.avatica.Meta.ExecuteBatchResult	prepareAndExecuteBatch(org.apache.calcite.avatica.Meta.StatementHandle statementHandle, List<String> queries)
void	rollback(org.apache.calcite.avatica.Meta.ConnectionHandle connectionHandle)
boolean	syncResults(org.apache.calcite.avatica.Meta.StatementHandle statementHandle, org.apache.calcite.avatica.QueryState queryState, long offset)

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

checkParameterValueHasNull, closeConnection, collect, collect, columnMetaData, columnMetaData, columnMetaData, columnMetaData, connectionSync, createCursor, createEmptyResultSet, createIterable, createResultSet, createStatement, fetch, fieldMetaData, getAttributes, getBestRowIdentifier, getCatalogs, getClientInfoProperties, getColumnNullability, getColumnPrivileges, getColumns, getCrossReference, getDatabaseProperties, getExportedKeys, getFunctionColumns, getFunctions, getImportedKeys, getIndexInfo, getPrimaryKeys, getProcedureColumns, getProcedures, getPseudoColumns, getSchemas, getSuperTables, getSuperTypes, getTablePrivileges, getTables, getTableTypes, getTypeInfo, getUDTs, getVersionColumns, openConnection

Methods inherited from class java.lang.Object

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

Constructor Detail

ArrowFlightMetaImpl

public ArrowFlightMetaImpl(org.apache.calcite.avatica.AvaticaConnection connection)

Constructs a MetaImpl object specific for Arrow Flight.

Parameters:

connection - A AvaticaConnection.

Method Detail

closeStatement

public void closeStatement(org.apache.calcite.avatica.Meta.StatementHandle statementHandle)

commit

public void commit(org.apache.calcite.avatica.Meta.ConnectionHandle connectionHandle)

execute

public org.apache.calcite.avatica.Meta.ExecuteResult execute(org.apache.calcite.avatica.Meta.StatementHandle statementHandle,
                                                             List<org.apache.calcite.avatica.remote.TypedValue> typedValues,
                                                             long maxRowCount)

execute

public org.apache.calcite.avatica.Meta.ExecuteResult execute(org.apache.calcite.avatica.Meta.StatementHandle statementHandle,
                                                             List<org.apache.calcite.avatica.remote.TypedValue> typedValues,
                                                             int maxRowsInFirstFrame)

executeBatch

public org.apache.calcite.avatica.Meta.ExecuteBatchResult executeBatch(org.apache.calcite.avatica.Meta.StatementHandle statementHandle,
                                                                       List<List<org.apache.calcite.avatica.remote.TypedValue>> parameterValuesList)
                                                                throws IllegalStateException

Throws:

IllegalStateException

fetch

public org.apache.calcite.avatica.Meta.Frame fetch(org.apache.calcite.avatica.Meta.StatementHandle statementHandle,
                                                   long offset,
                                                   int fetchMaxRowCount)

prepare

public org.apache.calcite.avatica.Meta.StatementHandle prepare(org.apache.calcite.avatica.Meta.ConnectionHandle connectionHandle,
                                                               String query,
                                                               long maxRowCount)

prepareAndExecute

public org.apache.calcite.avatica.Meta.ExecuteResult prepareAndExecute(org.apache.calcite.avatica.Meta.StatementHandle statementHandle,
                                                                       String query,
                                                                       long maxRowCount,
                                                                       org.apache.calcite.avatica.Meta.PrepareCallback prepareCallback)
                                                                throws org.apache.calcite.avatica.NoSuchStatementException

Throws:

org.apache.calcite.avatica.NoSuchStatementException

prepareAndExecute

public org.apache.calcite.avatica.Meta.ExecuteResult prepareAndExecute(org.apache.calcite.avatica.Meta.StatementHandle handle,
                                                                       String query,
                                                                       long maxRowCount,
                                                                       int maxRowsInFirstFrame,
                                                                       org.apache.calcite.avatica.Meta.PrepareCallback callback)
                                                                throws org.apache.calcite.avatica.NoSuchStatementException

Throws:

org.apache.calcite.avatica.NoSuchStatementException

prepareAndExecuteBatch

public org.apache.calcite.avatica.Meta.ExecuteBatchResult prepareAndExecuteBatch(org.apache.calcite.avatica.Meta.StatementHandle statementHandle,
                                                                                 List<String> queries)
                                                                          throws org.apache.calcite.avatica.NoSuchStatementException

Throws:

org.apache.calcite.avatica.NoSuchStatementException

rollback

public void rollback(org.apache.calcite.avatica.Meta.ConnectionHandle connectionHandle)

syncResults

public boolean syncResults(org.apache.calcite.avatica.Meta.StatementHandle statementHandle,
                           org.apache.calcite.avatica.QueryState queryState,
                           long offset)
                    throws org.apache.calcite.avatica.NoSuchStatementException

Throws:

org.apache.calcite.avatica.NoSuchStatementException