Package org.apache.arrow.adbc.driver.flightsql

Class FlightSqlClientWithCallOptions

java.lang.Object
org.apache.arrow.adbc.driver.flightsql.FlightSqlClientWithCallOptions
All Implemented Interfaces:
AutoCloseable
public class FlightSqlClientWithCallOptions extends Object implements AutoCloseable
A wrapper around FlightSqlClient which automatically adds CallOptions to each RPC call.

  • Constructor Summary

    Constructors
    Constructor
    Description
    FlightSqlClientWithCallOptions(org.apache.arrow.flight.sql.FlightSqlClient client, org.apache.arrow.flight.CallOption... options)
     

  • Method Summary

    Modifier and Type
    Method
    Description
    org.apache.arrow.flight.sql.FlightSqlClient.Savepoint
    beginSavepoint(org.apache.arrow.flight.sql.FlightSqlClient.Transaction transaction, String name, org.apache.arrow.flight.CallOption... options)
     
    org.apache.arrow.flight.sql.FlightSqlClient.Transaction
    beginTransaction(org.apache.arrow.flight.CallOption... options)
     
    org.apache.arrow.flight.CancelFlightInfoResult
    cancelFlightInfo(org.apache.arrow.flight.CancelFlightInfoRequest request, org.apache.arrow.flight.CallOption... options)
     
    org.apache.arrow.flight.sql.CancelResult
    cancelQuery(org.apache.arrow.flight.FlightInfo info, org.apache.arrow.flight.CallOption... options)
     
    void
    close()
     
    void
    commit(org.apache.arrow.flight.sql.FlightSqlClient.Transaction transaction, org.apache.arrow.flight.CallOption... options)
     
    org.apache.arrow.flight.FlightInfo
    execute(String query, org.apache.arrow.flight.CallOption... options)
     
    org.apache.arrow.flight.FlightInfo
    execute(String query, org.apache.arrow.flight.sql.FlightSqlClient.Transaction transaction, org.apache.arrow.flight.CallOption... options)
     
    org.apache.arrow.flight.FlightInfo
    executePrepared(org.apache.arrow.flight.sql.FlightSqlClient.PreparedStatement statement, org.apache.arrow.flight.CallOption... options)
     
    long
    executePreparedUpdate(org.apache.arrow.flight.sql.FlightSqlClient.PreparedStatement statement, org.apache.arrow.flight.CallOption... options)
     
    org.apache.arrow.flight.FlightInfo
    executeSubstrait(org.apache.arrow.flight.sql.FlightSqlClient.SubstraitPlan plan, org.apache.arrow.flight.CallOption... options)
     
    org.apache.arrow.flight.FlightInfo
    executeSubstrait(org.apache.arrow.flight.sql.FlightSqlClient.SubstraitPlan plan, org.apache.arrow.flight.sql.FlightSqlClient.Transaction transaction, org.apache.arrow.flight.CallOption... options)
     
    long
    executeSubstraitUpdate(org.apache.arrow.flight.sql.FlightSqlClient.SubstraitPlan plan, org.apache.arrow.flight.CallOption... options)
     
    long
    executeSubstraitUpdate(org.apache.arrow.flight.sql.FlightSqlClient.SubstraitPlan plan, org.apache.arrow.flight.sql.FlightSqlClient.Transaction transaction, org.apache.arrow.flight.CallOption... options)
     
    long
    executeUpdate(String query, org.apache.arrow.flight.CallOption... options)
     
    long
    executeUpdate(String query, org.apache.arrow.flight.sql.FlightSqlClient.Transaction transaction, org.apache.arrow.flight.CallOption... options)
     
    org.apache.arrow.flight.FlightInfo
    getCatalogs(org.apache.arrow.flight.CallOption... options)
     
    org.apache.arrow.flight.SchemaResult
    getCatalogsSchema(org.apache.arrow.flight.CallOption... options)
     
    org.apache.arrow.flight.FlightInfo
    getCrossReference(org.apache.arrow.flight.sql.util.TableRef pkTableRef, org.apache.arrow.flight.sql.util.TableRef fkTableRef, org.apache.arrow.flight.CallOption... options)
     
    org.apache.arrow.flight.SchemaResult
    getCrossReferenceSchema(org.apache.arrow.flight.CallOption... options)
     
    org.apache.arrow.flight.SchemaResult
    getExecuteSchema(String query, org.apache.arrow.flight.CallOption... options)
     
    org.apache.arrow.flight.SchemaResult
    getExecuteSchema(String query, org.apache.arrow.flight.sql.FlightSqlClient.Transaction transaction, org.apache.arrow.flight.CallOption... options)
     
    org.apache.arrow.flight.SchemaResult
    getExecuteSubstraitSchema(org.apache.arrow.flight.sql.FlightSqlClient.SubstraitPlan substraitPlan, org.apache.arrow.flight.CallOption... options)
     
    org.apache.arrow.flight.SchemaResult
    getExecuteSubstraitSchema(org.apache.arrow.flight.sql.FlightSqlClient.SubstraitPlan plan, org.apache.arrow.flight.sql.FlightSqlClient.Transaction transaction, org.apache.arrow.flight.CallOption... options)
     
    org.apache.arrow.flight.FlightInfo
    getExportedKeys(org.apache.arrow.flight.sql.util.TableRef tableRef, org.apache.arrow.flight.CallOption... options)
     
    org.apache.arrow.flight.SchemaResult
    getExportedKeysSchema(org.apache.arrow.flight.CallOption... options)
     
    org.apache.arrow.flight.FlightInfo
    getImportedKeys(org.apache.arrow.flight.sql.util.TableRef tableRef, org.apache.arrow.flight.CallOption... options)
     
    org.apache.arrow.flight.SchemaResult
    getImportedKeysSchema(org.apache.arrow.flight.CallOption... options)
     
    org.apache.arrow.flight.FlightInfo
    getPrimaryKeys(org.apache.arrow.flight.sql.util.TableRef tableRef, org.apache.arrow.flight.CallOption... options)
     
    org.apache.arrow.flight.SchemaResult
    getPrimaryKeysSchema(org.apache.arrow.flight.CallOption... options)
     
    org.apache.arrow.flight.SchemaResult
    getSchema(org.apache.arrow.flight.FlightDescriptor descriptor, org.apache.arrow.flight.CallOption... options)
     
    org.apache.arrow.flight.FlightInfo
    getSchemas(String catalog, String dbSchemaFilterPattern, org.apache.arrow.flight.CallOption... options)
     
    org.apache.arrow.flight.SchemaResult
    getSchemasSchema(org.apache.arrow.flight.CallOption... options)
     
    org.apache.arrow.flight.FlightInfo
    getSqlInfo(int[] info, org.apache.arrow.flight.CallOption... options)
     
    org.apache.arrow.flight.FlightInfo
    getSqlInfo(Iterable<Integer> info, org.apache.arrow.flight.CallOption... options)
     
    org.apache.arrow.flight.FlightInfo
    getSqlInfo(org.apache.arrow.flight.sql.impl.FlightSql.SqlInfo... info)
     
    org.apache.arrow.flight.FlightInfo
    getSqlInfo(org.apache.arrow.flight.sql.impl.FlightSql.SqlInfo[] info, org.apache.arrow.flight.CallOption... options)
     
    org.apache.arrow.flight.SchemaResult
    getSqlInfoSchema(org.apache.arrow.flight.CallOption... options)
     
    org.apache.arrow.flight.FlightStream
    getStream(org.apache.arrow.flight.Ticket ticket, org.apache.arrow.flight.CallOption... options)
     
    org.apache.arrow.flight.FlightInfo
    getTables(String catalog, String dbSchemaFilterPattern, String tableFilterPattern, @Nullable List<String> tableTypes, boolean includeSchema, org.apache.arrow.flight.CallOption... options)
     
    org.apache.arrow.flight.SchemaResult
    getTablesSchema(boolean includeSchema, org.apache.arrow.flight.CallOption... options)
     
    org.apache.arrow.flight.FlightInfo
    getTableTypes(org.apache.arrow.flight.CallOption... options)
     
    org.apache.arrow.flight.SchemaResult
    getTableTypesSchema(org.apache.arrow.flight.CallOption... options)
     
    org.apache.arrow.flight.FlightInfo
    getXdbcTypeInfo(int dataType, org.apache.arrow.flight.CallOption... options)
     
    org.apache.arrow.flight.FlightInfo
    getXdbcTypeInfo(org.apache.arrow.flight.CallOption... options)
     
    org.apache.arrow.flight.SchemaResult
    getXdbcTypeInfoSchema(org.apache.arrow.flight.CallOption... options)
     
    org.apache.arrow.flight.sql.FlightSqlClient.PreparedStatement
    prepare(String query, org.apache.arrow.flight.CallOption... options)
     
    org.apache.arrow.flight.sql.FlightSqlClient.PreparedStatement
    prepare(String query, org.apache.arrow.flight.sql.FlightSqlClient.Transaction transaction, org.apache.arrow.flight.CallOption... options)
     
    org.apache.arrow.flight.sql.FlightSqlClient.PreparedStatement
    prepare(org.apache.arrow.flight.sql.FlightSqlClient.SubstraitPlan plan, org.apache.arrow.flight.CallOption... options)
     
    org.apache.arrow.flight.sql.FlightSqlClient.PreparedStatement
    prepare(org.apache.arrow.flight.sql.FlightSqlClient.SubstraitPlan plan, org.apache.arrow.flight.sql.FlightSqlClient.Transaction transaction, org.apache.arrow.flight.CallOption... options)
     
    void
    release(org.apache.arrow.flight.sql.FlightSqlClient.Savepoint savepoint, org.apache.arrow.flight.CallOption... options)
     
    org.apache.arrow.flight.FlightEndpoint
    renewFlightEndpoint(org.apache.arrow.flight.RenewFlightEndpointRequest request, org.apache.arrow.flight.CallOption... options)
     
    void
    rollback(org.apache.arrow.flight.sql.FlightSqlClient.Savepoint savepoint, org.apache.arrow.flight.CallOption... options)
     
    void
    rollback(org.apache.arrow.flight.sql.FlightSqlClient.Transaction transaction, org.apache.arrow.flight.CallOption... options)
     

    Methods inherited from class java.lang.Object

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

  • Constructor Details

    • FlightSqlClientWithCallOptions

      public FlightSqlClientWithCallOptions(org.apache.arrow.flight.sql.FlightSqlClient client, org.apache.arrow.flight.CallOption... options)

  • Method Details

    • execute

      public org.apache.arrow.flight.FlightInfo execute(String query, org.apache.arrow.flight.CallOption... options)

    • execute

      public org.apache.arrow.flight.FlightInfo execute(String query, org.apache.arrow.flight.sql.FlightSqlClient.Transaction transaction, org.apache.arrow.flight.CallOption... options)

    • executePrepared

      public org.apache.arrow.flight.FlightInfo executePrepared(org.apache.arrow.flight.sql.FlightSqlClient.PreparedStatement statement, org.apache.arrow.flight.CallOption... options)

    • executeSubstrait

      public org.apache.arrow.flight.FlightInfo executeSubstrait(org.apache.arrow.flight.sql.FlightSqlClient.SubstraitPlan plan, org.apache.arrow.flight.CallOption... options)

    • executeSubstrait

      public org.apache.arrow.flight.FlightInfo executeSubstrait(org.apache.arrow.flight.sql.FlightSqlClient.SubstraitPlan plan, org.apache.arrow.flight.sql.FlightSqlClient.Transaction transaction, org.apache.arrow.flight.CallOption... options)

    • getExecuteSchema

      public org.apache.arrow.flight.SchemaResult getExecuteSchema(String query, org.apache.arrow.flight.sql.FlightSqlClient.Transaction transaction, org.apache.arrow.flight.CallOption... options)

    • getExecuteSchema

      public org.apache.arrow.flight.SchemaResult getExecuteSchema(String query, org.apache.arrow.flight.CallOption... options)

    • getExecuteSubstraitSchema

      public org.apache.arrow.flight.SchemaResult getExecuteSubstraitSchema(org.apache.arrow.flight.sql.FlightSqlClient.SubstraitPlan plan, org.apache.arrow.flight.sql.FlightSqlClient.Transaction transaction, org.apache.arrow.flight.CallOption... options)

    • getExecuteSubstraitSchema

      public org.apache.arrow.flight.SchemaResult getExecuteSubstraitSchema(org.apache.arrow.flight.sql.FlightSqlClient.SubstraitPlan substraitPlan, org.apache.arrow.flight.CallOption... options)

    • executeUpdate

      public long executeUpdate(String query, org.apache.arrow.flight.CallOption... options)

    • executeUpdate

      public long executeUpdate(String query, org.apache.arrow.flight.sql.FlightSqlClient.Transaction transaction, org.apache.arrow.flight.CallOption... options)

    • executePreparedUpdate

      public long executePreparedUpdate(org.apache.arrow.flight.sql.FlightSqlClient.PreparedStatement statement, org.apache.arrow.flight.CallOption... options)

    • executeSubstraitUpdate

      public long executeSubstraitUpdate(org.apache.arrow.flight.sql.FlightSqlClient.SubstraitPlan plan, org.apache.arrow.flight.CallOption... options)

    • executeSubstraitUpdate

      public long executeSubstraitUpdate(org.apache.arrow.flight.sql.FlightSqlClient.SubstraitPlan plan, org.apache.arrow.flight.sql.FlightSqlClient.Transaction transaction, org.apache.arrow.flight.CallOption... options)

    • getCatalogs

      public org.apache.arrow.flight.FlightInfo getCatalogs(org.apache.arrow.flight.CallOption... options)

    • getCatalogsSchema

      public org.apache.arrow.flight.SchemaResult getCatalogsSchema(org.apache.arrow.flight.CallOption... options)

    • getSchemas

      public org.apache.arrow.flight.FlightInfo getSchemas(String catalog, String dbSchemaFilterPattern, org.apache.arrow.flight.CallOption... options)

    • getSchemasSchema

      public org.apache.arrow.flight.SchemaResult getSchemasSchema(org.apache.arrow.flight.CallOption... options)

    • getSchema

      public org.apache.arrow.flight.SchemaResult getSchema(org.apache.arrow.flight.FlightDescriptor descriptor, org.apache.arrow.flight.CallOption... options)

    • getStream

      public org.apache.arrow.flight.FlightStream getStream(org.apache.arrow.flight.Ticket ticket, org.apache.arrow.flight.CallOption... options)

    • getSqlInfo

      public org.apache.arrow.flight.FlightInfo getSqlInfo(org.apache.arrow.flight.sql.impl.FlightSql.SqlInfo... info)

    • getSqlInfo

      public org.apache.arrow.flight.FlightInfo getSqlInfo(org.apache.arrow.flight.sql.impl.FlightSql.SqlInfo[] info, org.apache.arrow.flight.CallOption... options)

    • getSqlInfo

      public org.apache.arrow.flight.FlightInfo getSqlInfo(int[] info, org.apache.arrow.flight.CallOption... options)

    • getSqlInfo

      public org.apache.arrow.flight.FlightInfo getSqlInfo(Iterable<Integer> info, org.apache.arrow.flight.CallOption... options)

    • getSqlInfoSchema

      public org.apache.arrow.flight.SchemaResult getSqlInfoSchema(org.apache.arrow.flight.CallOption... options)

    • getXdbcTypeInfo

      public org.apache.arrow.flight.FlightInfo getXdbcTypeInfo(int dataType, org.apache.arrow.flight.CallOption... options)

    • getXdbcTypeInfo

      public org.apache.arrow.flight.FlightInfo getXdbcTypeInfo(org.apache.arrow.flight.CallOption... options)

    • getXdbcTypeInfoSchema

      public org.apache.arrow.flight.SchemaResult getXdbcTypeInfoSchema(org.apache.arrow.flight.CallOption... options)

    • getTables

      public org.apache.arrow.flight.FlightInfo getTables(String catalog, String dbSchemaFilterPattern, String tableFilterPattern, @Nullable List<String> tableTypes, boolean includeSchema, org.apache.arrow.flight.CallOption... options)

    • getTablesSchema

      public org.apache.arrow.flight.SchemaResult getTablesSchema(boolean includeSchema, org.apache.arrow.flight.CallOption... options)

    • getPrimaryKeys

      public org.apache.arrow.flight.FlightInfo getPrimaryKeys(org.apache.arrow.flight.sql.util.TableRef tableRef, org.apache.arrow.flight.CallOption... options)

    • getPrimaryKeysSchema

      public org.apache.arrow.flight.SchemaResult getPrimaryKeysSchema(org.apache.arrow.flight.CallOption... options)

    • getExportedKeys

      public org.apache.arrow.flight.FlightInfo getExportedKeys(org.apache.arrow.flight.sql.util.TableRef tableRef, org.apache.arrow.flight.CallOption... options)

    • getExportedKeysSchema

      public org.apache.arrow.flight.SchemaResult getExportedKeysSchema(org.apache.arrow.flight.CallOption... options)

    • getImportedKeys

      public org.apache.arrow.flight.FlightInfo getImportedKeys(org.apache.arrow.flight.sql.util.TableRef tableRef, org.apache.arrow.flight.CallOption... options)

    • getImportedKeysSchema

      public org.apache.arrow.flight.SchemaResult getImportedKeysSchema(org.apache.arrow.flight.CallOption... options)

    • getCrossReference

      public org.apache.arrow.flight.FlightInfo getCrossReference(org.apache.arrow.flight.sql.util.TableRef pkTableRef, org.apache.arrow.flight.sql.util.TableRef fkTableRef, org.apache.arrow.flight.CallOption... options)

    • getCrossReferenceSchema

      public org.apache.arrow.flight.SchemaResult getCrossReferenceSchema(org.apache.arrow.flight.CallOption... options)

    • getTableTypes

      public org.apache.arrow.flight.FlightInfo getTableTypes(org.apache.arrow.flight.CallOption... options)

    • getTableTypesSchema

      public org.apache.arrow.flight.SchemaResult getTableTypesSchema(org.apache.arrow.flight.CallOption... options)

    • prepare

      public org.apache.arrow.flight.sql.FlightSqlClient.PreparedStatement prepare(String query, org.apache.arrow.flight.CallOption... options)

    • prepare

      public org.apache.arrow.flight.sql.FlightSqlClient.PreparedStatement prepare(String query, org.apache.arrow.flight.sql.FlightSqlClient.Transaction transaction, org.apache.arrow.flight.CallOption... options)

    • prepare

      public org.apache.arrow.flight.sql.FlightSqlClient.PreparedStatement prepare(org.apache.arrow.flight.sql.FlightSqlClient.SubstraitPlan plan, org.apache.arrow.flight.CallOption... options)

    • prepare

      public org.apache.arrow.flight.sql.FlightSqlClient.PreparedStatement prepare(org.apache.arrow.flight.sql.FlightSqlClient.SubstraitPlan plan, org.apache.arrow.flight.sql.FlightSqlClient.Transaction transaction, org.apache.arrow.flight.CallOption... options)

    • beginTransaction

      public org.apache.arrow.flight.sql.FlightSqlClient.Transaction beginTransaction(org.apache.arrow.flight.CallOption... options)

    • beginSavepoint

      public org.apache.arrow.flight.sql.FlightSqlClient.Savepoint beginSavepoint(org.apache.arrow.flight.sql.FlightSqlClient.Transaction transaction, String name, org.apache.arrow.flight.CallOption... options)

    • commit

      public void commit(org.apache.arrow.flight.sql.FlightSqlClient.Transaction transaction, org.apache.arrow.flight.CallOption... options)

    • release

      public void release(org.apache.arrow.flight.sql.FlightSqlClient.Savepoint savepoint, org.apache.arrow.flight.CallOption... options)

    • rollback

      public void rollback(org.apache.arrow.flight.sql.FlightSqlClient.Transaction transaction, org.apache.arrow.flight.CallOption... options)

    • rollback

      public void rollback(org.apache.arrow.flight.sql.FlightSqlClient.Savepoint savepoint, org.apache.arrow.flight.CallOption... options)

    • cancelFlightInfo

      public org.apache.arrow.flight.CancelFlightInfoResult cancelFlightInfo(org.apache.arrow.flight.CancelFlightInfoRequest request, org.apache.arrow.flight.CallOption... options)

    • cancelQuery

      public org.apache.arrow.flight.sql.CancelResult cancelQuery(org.apache.arrow.flight.FlightInfo info, org.apache.arrow.flight.CallOption... options)

    • renewFlightEndpoint

      public org.apache.arrow.flight.FlightEndpoint renewFlightEndpoint(org.apache.arrow.flight.RenewFlightEndpointRequest request, org.apache.arrow.flight.CallOption... options)

    • close

      public void close() throws Exception
      Specified by:
      close in interface AutoCloseable
      Throws:
      Exception