Modifier and Type | Method and Description |
---|---|
ArrowFlightSqlClientHandler.Builder |
ArrowFlightSqlClientHandler.Builder.withCallOptions(CallOption... options)
Adds the provided
CallOption s to this handler. |
Modifier and Type | Method and Description |
---|---|
static ArrowFlightSqlClientHandler |
ArrowFlightSqlClientHandler.createNewHandler(FlightClient client,
Collection<CallOption> options)
|
ArrowFlightSqlClientHandler.Builder |
ArrowFlightSqlClientHandler.Builder.withCallOptions(Collection<CallOption> options)
Adds the provided
CallOption s to this handler. |
Modifier and Type | Method and Description |
---|---|
static CredentialCallOption |
ClientAuthenticationUtils.getAuthenticate(FlightClient client,
CredentialCallOption credential,
CallOption... options)
Gets the
CredentialCallOption for the provided authentication info. |
static CredentialCallOption |
ClientAuthenticationUtils.getAuthenticate(FlightClient client,
String username,
String password,
ClientIncomingAuthHeaderMiddleware.Factory factory,
CallOption... options)
Gets the
CredentialCallOption for the provided authentication info. |
Modifier and Type | Method and Description |
---|---|
CallOption |
ArrowFlightConnectionConfigImpl.toCallOption()
Gets the
CallOption s from this ConnectionConfig . |
Modifier and Type | Interface and Description |
---|---|
static interface |
CallOptions.GrpcCallOption
CallOptions specific to GRPC stubs.
|
Modifier and Type | Class and Description |
---|---|
class |
HeaderCallOption
Method option for supplying headers to method calls.
|
Modifier and Type | Method and Description |
---|---|
static CallOption |
CallOptions.timeout(long duration,
TimeUnit unit) |
Modifier and Type | Method and Description |
---|---|
void |
FlightClient.authenticate(ClientAuthHandler handler,
CallOption... options)
Authenticates against the Flight service.
|
CancelFlightInfoResult |
FlightClient.cancelFlightInfo(CancelFlightInfoRequest request,
CallOption... options)
Cancel execution of a distributed query.
|
Iterator<Result> |
FlightClient.doAction(Action action,
CallOption... options)
Performs an action on the Flight service.
|
FlightClient.ExchangeReaderWriter |
FlightClient.doExchange(FlightDescriptor descriptor,
CallOption... options)
Initiate a bidirectional data exchange with the server.
|
FlightInfo |
FlightClient.getInfo(FlightDescriptor descriptor,
CallOption... options)
Get info on a stream.
|
SchemaResult |
FlightClient.getSchema(FlightDescriptor descriptor,
CallOption... options)
Get schema for a stream.
|
FlightStream |
FlightClient.getStream(Ticket ticket,
CallOption... options)
Retrieve a stream from the server.
|
void |
FlightClient.handshake(CallOption... options)
Executes the handshake against the Flight service.
|
Iterable<ActionType> |
FlightClient.listActions(CallOption... options)
Lists actions available on the Flight service.
|
Iterable<FlightInfo> |
FlightClient.listFlights(Criteria criteria,
CallOption... options)
Get a list of available flights.
|
FlightEndpoint |
FlightClient.renewFlightEndpoint(RenewFlightEndpointRequest request,
CallOption... options)
Request the server to extend the lifetime of a query result set.
|
FlightClient.ClientStreamListener |
FlightClient.startPut(FlightDescriptor descriptor,
FlightClient.PutListener metadataListener,
CallOption... options)
Create or append a descriptor with another stream.
|
FlightClient.ClientStreamListener |
FlightClient.startPut(FlightDescriptor descriptor,
VectorSchemaRoot root,
DictionaryProvider provider,
FlightClient.PutListener metadataListener,
CallOption... options)
Create or append a descriptor with another stream.
|
FlightClient.ClientStreamListener |
FlightClient.startPut(FlightDescriptor descriptor,
VectorSchemaRoot root,
FlightClient.PutListener metadataListener,
CallOption... options)
Create or append a descriptor with another stream.
|
Modifier and Type | Class and Description |
---|---|
class |
CredentialCallOption
Method option for supplying credentials to method calls.
|
Modifier and Type | Method and Description |
---|---|
FlightSqlClient.Savepoint |
FlightSqlClient.beginSavepoint(FlightSqlClient.Transaction transaction,
String name,
CallOption... options)
Create a savepoint within a transaction.
|
FlightSqlClient.Transaction |
FlightSqlClient.beginTransaction(CallOption... options)
Begin a transaction.
|
CancelFlightInfoResult |
FlightSqlClient.cancelFlightInfo(CancelFlightInfoRequest request,
CallOption... options)
Cancel execution of a distributed query.
|
CancelResult |
FlightSqlClient.cancelQuery(FlightInfo info,
CallOption... options)
|
void |
FlightSqlClient.PreparedStatement.close(CallOption... options)
Closes the client.
|
void |
FlightSqlClient.commit(FlightSqlClient.Transaction transaction,
CallOption... options)
Commit a transaction.
|
FlightInfo |
FlightSqlClient.PreparedStatement.execute(CallOption... options)
Executes the prepared statement query on the server.
|
FlightInfo |
FlightSqlClient.execute(String query,
CallOption... options)
Execute a query on the server.
|
FlightInfo |
FlightSqlClient.execute(String query,
FlightSqlClient.Transaction transaction,
CallOption... options)
Execute a query on the server.
|
FlightInfo |
FlightSqlClient.executeSubstrait(FlightSqlClient.SubstraitPlan plan,
CallOption... options)
Execute a Substrait plan on the server.
|
FlightInfo |
FlightSqlClient.executeSubstrait(FlightSqlClient.SubstraitPlan plan,
FlightSqlClient.Transaction transaction,
CallOption... options)
Execute a Substrait plan on the server.
|
long |
FlightSqlClient.executeSubstraitUpdate(FlightSqlClient.SubstraitPlan plan,
CallOption... options)
Execute an update query on the server.
|
long |
FlightSqlClient.executeSubstraitUpdate(FlightSqlClient.SubstraitPlan plan,
FlightSqlClient.Transaction transaction,
CallOption... options)
Execute an update query on the server.
|
long |
FlightSqlClient.PreparedStatement.executeUpdate(CallOption... options)
Executes the prepared statement update on the server.
|
long |
FlightSqlClient.executeUpdate(String query,
CallOption... options)
Execute an update query on the server.
|
long |
FlightSqlClient.executeUpdate(String query,
FlightSqlClient.Transaction transaction,
CallOption... options)
Execute an update query on the server.
|
SchemaResult |
FlightSqlClient.PreparedStatement.fetchSchema(CallOption... options)
Get the schema of the result set (should be identical to
FlightSqlClient.PreparedStatement.getResultSetSchema() ). |
FlightInfo |
FlightSqlClient.getCatalogs(CallOption... options)
Request a list of catalogs.
|
SchemaResult |
FlightSqlClient.getCatalogsSchema(CallOption... options)
Get the schema of
FlightSqlClient.getCatalogs(CallOption...) from the server. |
FlightInfo |
FlightSqlClient.getCrossReference(TableRef pkTableRef,
TableRef fkTableRef,
CallOption... options)
Retrieves a description of the foreign key columns that reference the given table's
primary key columns (the foreign keys exported by a table).
|
SchemaResult |
FlightSqlClient.getCrossReferenceSchema(CallOption... options)
Get the schema of
FlightSqlClient.getCrossReference(TableRef, TableRef, CallOption...) from the server. |
SchemaResult |
FlightSqlClient.getExecuteSchema(String query,
CallOption... options)
Get the schema of the result set of a query.
|
SchemaResult |
FlightSqlClient.getExecuteSchema(String query,
FlightSqlClient.Transaction transaction,
CallOption... options)
Get the schema of the result set of a query.
|
SchemaResult |
FlightSqlClient.getExecuteSubstraitSchema(FlightSqlClient.SubstraitPlan substraitPlan,
CallOption... options)
Get the schema of the result set of a Substrait plan.
|
SchemaResult |
FlightSqlClient.getExecuteSubstraitSchema(FlightSqlClient.SubstraitPlan plan,
FlightSqlClient.Transaction transaction,
CallOption... options)
Get the schema of the result set of a Substrait plan.
|
FlightInfo |
FlightSqlClient.getExportedKeys(TableRef tableRef,
CallOption... options)
Retrieves a description about the foreign key columns that reference the primary key columns of the given table.
|
SchemaResult |
FlightSqlClient.getExportedKeysSchema(CallOption... options)
Get the schema of
FlightSqlClient.getExportedKeys(TableRef, CallOption...) from the server. |
FlightInfo |
FlightSqlClient.getImportedKeys(TableRef tableRef,
CallOption... options)
Retrieves the foreign key columns for the given table.
|
SchemaResult |
FlightSqlClient.getImportedKeysSchema(CallOption... options)
Get the schema of
FlightSqlClient.getImportedKeys(TableRef, CallOption...) from the server. |
FlightInfo |
FlightSqlClient.getPrimaryKeys(TableRef tableRef,
CallOption... options)
Request the primary keys for a table.
|
SchemaResult |
FlightSqlClient.getPrimaryKeysSchema(CallOption... options)
Get the schema of
FlightSqlClient.getPrimaryKeys(TableRef, CallOption...) from the server. |
SchemaResult |
FlightSqlClient.getSchema(FlightDescriptor descriptor,
CallOption... options)
Get schema for a stream.
|
FlightInfo |
FlightSqlClient.getSchemas(String catalog,
String dbSchemaFilterPattern,
CallOption... options)
Request a list of schemas.
|
SchemaResult |
FlightSqlClient.getSchemasSchema(CallOption... options)
Get the schema of
FlightSqlClient.getSchemas(String, String, CallOption...) from the server. |
FlightInfo |
FlightSqlClient.getSqlInfo(FlightSql.SqlInfo[] info,
CallOption... options)
Request a set of Flight SQL metadata.
|
FlightInfo |
FlightSqlClient.getSqlInfo(int[] info,
CallOption... options)
Request a set of Flight SQL metadata.
|
FlightInfo |
FlightSqlClient.getSqlInfo(Iterable<Integer> info,
CallOption... options)
Request a set of Flight SQL metadata.
|
SchemaResult |
FlightSqlClient.getSqlInfoSchema(CallOption... options)
Get the schema of
#getSqlInfo(SqlInfo...) from the server. |
FlightStream |
FlightSqlClient.getStream(Ticket ticket,
CallOption... options)
Retrieve a stream from the server.
|
FlightInfo |
FlightSqlClient.getTables(String catalog,
String dbSchemaFilterPattern,
String tableFilterPattern,
List<String> tableTypes,
boolean includeSchema,
CallOption... options)
Request a list of tables.
|
SchemaResult |
FlightSqlClient.getTablesSchema(boolean includeSchema,
CallOption... options)
Get the schema of
FlightSqlClient.getTables(String, String, String, List, boolean, CallOption...) from the server. |
FlightInfo |
FlightSqlClient.getTableTypes(CallOption... options)
Request a list of table types.
|
SchemaResult |
FlightSqlClient.getTableTypesSchema(CallOption... options)
Get the schema of
FlightSqlClient.getTableTypes(CallOption...) from the server. |
FlightInfo |
FlightSqlClient.getXdbcTypeInfo(CallOption... options)
Request the information about all the data types supported.
|
FlightInfo |
FlightSqlClient.getXdbcTypeInfo(int dataType,
CallOption... options)
Request the information about the data types supported related to
a filter data type.
|
SchemaResult |
FlightSqlClient.getXdbcTypeInfoSchema(CallOption... options)
Get the schema of
FlightSqlClient.getXdbcTypeInfo(CallOption...) from the server. |
FlightSqlClient.PreparedStatement |
FlightSqlClient.prepare(FlightSqlClient.SubstraitPlan plan,
CallOption... options)
Create a prepared statement for a Substrait plan on the server.
|
FlightSqlClient.PreparedStatement |
FlightSqlClient.prepare(FlightSqlClient.SubstraitPlan plan,
FlightSqlClient.Transaction transaction,
CallOption... options)
Create a prepared statement for a Substrait plan on the server.
|
FlightSqlClient.PreparedStatement |
FlightSqlClient.prepare(String query,
CallOption... options)
Create a prepared statement for a SQL query on the server.
|
FlightSqlClient.PreparedStatement |
FlightSqlClient.prepare(String query,
FlightSqlClient.Transaction transaction,
CallOption... options)
Create a prepared statement for a SQL query on the server.
|
void |
FlightSqlClient.release(FlightSqlClient.Savepoint savepoint,
CallOption... options)
Release a savepoint.
|
FlightEndpoint |
FlightSqlClient.renewFlightEndpoint(RenewFlightEndpointRequest request,
CallOption... options)
Request the server to extend the lifetime of a query result set.
|
void |
FlightSqlClient.rollback(FlightSqlClient.Savepoint savepoint,
CallOption... options)
Rollback to a savepoint.
|
void |
FlightSqlClient.rollback(FlightSqlClient.Transaction transaction,
CallOption... options)
Rollback a transaction.
|
Modifier and Type | Field and Description |
---|---|
List<CallOption> |
FlightSqlClientDemoApp.callOptions |
Modifier and Type | Method and Description |
---|---|
CallOption[] |
FlightSqlClientDemoApp.getCallOptions()
Gets the current
CallOption as an array; usually used as an
argument in FlightSqlClient methods. |
Copyright © 2023 The Apache Software Foundation. All rights reserved.