Package 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
    Description
    ArrowFlightMetaImpl(org.apache.calcite.avatica.AvaticaConnection connection)
    Constructs a MetaImpl object specific for Arrow Flight.

  • Method Summary

    Modifier and Type
    Method
    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 Details

    • ArrowFlightMetaImpl

      public ArrowFlightMetaImpl(org.apache.calcite.avatica.AvaticaConnection connection)
      Constructs a MetaImpl object specific for Arrow Flight.
      Parameters:
      connection - A AvaticaConnection.

  • Method Details

    • 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