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

Class 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

      All Methods Instance Methods Concrete Methods 
      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 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)  

    • Constructor Detail

      • FlightSqlClientWithCallOptions

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

    • Method Detail

      • 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)

      • 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)

      • 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)