default Runnable |
FlightSqlProducer.acceptPut(FlightProducer.CallContext context,
FlightStream flightStream,
FlightProducer.StreamListener<PutResult> ackStream)
Depending on the provided command, method either:
1.
|
Runnable |
FlightSqlProducer.acceptPutPreparedStatementQuery(FlightSql.CommandPreparedStatementQuery command,
FlightProducer.CallContext context,
FlightStream flightStream,
FlightProducer.StreamListener<PutResult> ackStream)
Accepts uploaded parameter values for a particular prepared statement query.
|
Runnable |
NoOpFlightSqlProducer.acceptPutPreparedStatementQuery(FlightSql.CommandPreparedStatementQuery command,
FlightProducer.CallContext context,
FlightStream flightStream,
FlightProducer.StreamListener<PutResult> ackStream) |
Runnable |
FlightSqlProducer.acceptPutPreparedStatementUpdate(FlightSql.CommandPreparedStatementUpdate command,
FlightProducer.CallContext context,
FlightStream flightStream,
FlightProducer.StreamListener<PutResult> ackStream)
Accepts uploaded data for a particular prepared statement data stream.
|
Runnable |
NoOpFlightSqlProducer.acceptPutPreparedStatementUpdate(FlightSql.CommandPreparedStatementUpdate command,
FlightProducer.CallContext context,
FlightStream flightStream,
FlightProducer.StreamListener<PutResult> ackStream) |
Runnable |
FlightSqlProducer.acceptPutStatement(FlightSql.CommandStatementUpdate command,
FlightProducer.CallContext context,
FlightStream flightStream,
FlightProducer.StreamListener<PutResult> ackStream)
Accepts uploaded data for a particular SQL query based data stream.
|
Runnable |
NoOpFlightSqlProducer.acceptPutStatement(FlightSql.CommandStatementUpdate command,
FlightProducer.CallContext context,
FlightStream flightStream,
FlightProducer.StreamListener<PutResult> ackStream) |
default Runnable |
FlightSqlProducer.acceptPutSubstraitPlan(FlightSql.CommandStatementSubstraitPlan command,
FlightProducer.CallContext context,
FlightStream flightStream,
FlightProducer.StreamListener<PutResult> ackStream)
Handle a Substrait plan with uploaded data.
|
default void |
FlightSqlProducer.beginSavepoint(FlightSql.ActionBeginSavepointRequest request,
FlightProducer.CallContext context,
FlightProducer.StreamListener<FlightSql.ActionBeginSavepointResult> listener)
Create a savepoint within a transaction.
|
default void |
FlightSqlProducer.beginTransaction(FlightSql.ActionBeginTransactionRequest request,
FlightProducer.CallContext context,
FlightProducer.StreamListener<FlightSql.ActionBeginTransactionResult> listener)
Begin a transaction.
|
default void |
FlightSqlProducer.cancelFlightInfo(CancelFlightInfoRequest request,
FlightProducer.CallContext context,
FlightProducer.StreamListener<CancelStatus> listener)
Explicitly cancel a query.
|
default void |
FlightSqlProducer.cancelQuery(FlightInfo info,
FlightProducer.CallContext context,
FlightProducer.StreamListener<CancelResult> listener)
|
void |
FlightSqlProducer.closePreparedStatement(FlightSql.ActionClosePreparedStatementRequest request,
FlightProducer.CallContext context,
FlightProducer.StreamListener<Result> listener)
Closes a prepared statement on the server.
|
void |
NoOpFlightSqlProducer.closePreparedStatement(FlightSql.ActionClosePreparedStatementRequest request,
FlightProducer.CallContext context,
FlightProducer.StreamListener<Result> listener) |
default void |
FlightSqlProducer.closeSession(CloseSessionRequest request,
FlightProducer.CallContext context,
FlightProducer.StreamListener<CloseSessionResult> listener)
Close/invalidate the session.
|
void |
FlightSqlProducer.createPreparedStatement(FlightSql.ActionCreatePreparedStatementRequest request,
FlightProducer.CallContext context,
FlightProducer.StreamListener<Result> listener)
|
void |
NoOpFlightSqlProducer.createPreparedStatement(FlightSql.ActionCreatePreparedStatementRequest request,
FlightProducer.CallContext context,
FlightProducer.StreamListener<Result> listener) |
default void |
FlightSqlProducer.createPreparedSubstraitPlan(FlightSql.ActionCreatePreparedSubstraitPlanRequest request,
FlightProducer.CallContext context,
FlightProducer.StreamListener<FlightSql.ActionCreatePreparedStatementResult> listener)
Pre-compile a Substrait plan.
|
default void |
FlightSqlProducer.doAction(FlightProducer.CallContext context,
Action action,
FlightProducer.StreamListener<Result> listener)
Performs the requested Flight SQL action.
|
default void |
FlightSqlProducer.endSavepoint(FlightSql.ActionEndSavepointRequest request,
FlightProducer.CallContext context,
FlightProducer.StreamListener<Result> listener)
Release or roll back to a savepoint.
|
default void |
FlightSqlProducer.endTransaction(FlightSql.ActionEndTransactionRequest request,
FlightProducer.CallContext context,
FlightProducer.StreamListener<Result> listener)
Commit or roll back to a transaction.
|
default FlightInfo |
FlightSqlProducer.getFlightInfo(FlightProducer.CallContext context,
FlightDescriptor descriptor)
Depending on the provided command, method either:
1.
|
FlightInfo |
FlightSqlProducer.getFlightInfoCatalogs(FlightSql.CommandGetCatalogs request,
FlightProducer.CallContext context,
FlightDescriptor descriptor)
|
FlightInfo |
NoOpFlightSqlProducer.getFlightInfoCatalogs(FlightSql.CommandGetCatalogs request,
FlightProducer.CallContext context,
FlightDescriptor descriptor) |
FlightInfo |
BasicFlightSqlProducer.getFlightInfoCatalogs(FlightSql.CommandGetCatalogs request,
FlightProducer.CallContext context,
FlightDescriptor descriptor) |
FlightInfo |
FlightSqlProducer.getFlightInfoCrossReference(FlightSql.CommandGetCrossReference request,
FlightProducer.CallContext context,
FlightDescriptor descriptor)
|
FlightInfo |
NoOpFlightSqlProducer.getFlightInfoCrossReference(FlightSql.CommandGetCrossReference request,
FlightProducer.CallContext context,
FlightDescriptor descriptor) |
FlightInfo |
BasicFlightSqlProducer.getFlightInfoCrossReference(FlightSql.CommandGetCrossReference request,
FlightProducer.CallContext context,
FlightDescriptor descriptor) |
FlightInfo |
FlightSqlProducer.getFlightInfoExportedKeys(FlightSql.CommandGetExportedKeys request,
FlightProducer.CallContext context,
FlightDescriptor descriptor)
|
FlightInfo |
NoOpFlightSqlProducer.getFlightInfoExportedKeys(FlightSql.CommandGetExportedKeys request,
FlightProducer.CallContext context,
FlightDescriptor descriptor) |
FlightInfo |
BasicFlightSqlProducer.getFlightInfoExportedKeys(FlightSql.CommandGetExportedKeys request,
FlightProducer.CallContext context,
FlightDescriptor descriptor) |
FlightInfo |
FlightSqlProducer.getFlightInfoImportedKeys(FlightSql.CommandGetImportedKeys request,
FlightProducer.CallContext context,
FlightDescriptor descriptor)
|
FlightInfo |
NoOpFlightSqlProducer.getFlightInfoImportedKeys(FlightSql.CommandGetImportedKeys request,
FlightProducer.CallContext context,
FlightDescriptor descriptor) |
FlightInfo |
BasicFlightSqlProducer.getFlightInfoImportedKeys(FlightSql.CommandGetImportedKeys request,
FlightProducer.CallContext context,
FlightDescriptor descriptor) |
FlightInfo |
FlightSqlProducer.getFlightInfoPreparedStatement(FlightSql.CommandPreparedStatementQuery command,
FlightProducer.CallContext context,
FlightDescriptor descriptor)
Gets information about a particular prepared statement data stream.
|
FlightInfo |
NoOpFlightSqlProducer.getFlightInfoPreparedStatement(FlightSql.CommandPreparedStatementQuery command,
FlightProducer.CallContext context,
FlightDescriptor descriptor) |
FlightInfo |
FlightSqlProducer.getFlightInfoPrimaryKeys(FlightSql.CommandGetPrimaryKeys request,
FlightProducer.CallContext context,
FlightDescriptor descriptor)
|
FlightInfo |
NoOpFlightSqlProducer.getFlightInfoPrimaryKeys(FlightSql.CommandGetPrimaryKeys request,
FlightProducer.CallContext context,
FlightDescriptor descriptor) |
FlightInfo |
BasicFlightSqlProducer.getFlightInfoPrimaryKeys(FlightSql.CommandGetPrimaryKeys request,
FlightProducer.CallContext context,
FlightDescriptor descriptor) |
FlightInfo |
FlightSqlProducer.getFlightInfoSchemas(FlightSql.CommandGetDbSchemas request,
FlightProducer.CallContext context,
FlightDescriptor descriptor)
|
FlightInfo |
NoOpFlightSqlProducer.getFlightInfoSchemas(FlightSql.CommandGetDbSchemas request,
FlightProducer.CallContext context,
FlightDescriptor descriptor) |
FlightInfo |
BasicFlightSqlProducer.getFlightInfoSchemas(FlightSql.CommandGetDbSchemas request,
FlightProducer.CallContext context,
FlightDescriptor descriptor) |
FlightInfo |
FlightSqlProducer.getFlightInfoSqlInfo(FlightSql.CommandGetSqlInfo request,
FlightProducer.CallContext context,
FlightDescriptor descriptor)
|
FlightInfo |
NoOpFlightSqlProducer.getFlightInfoSqlInfo(FlightSql.CommandGetSqlInfo request,
FlightProducer.CallContext context,
FlightDescriptor descriptor) |
FlightInfo |
BasicFlightSqlProducer.getFlightInfoSqlInfo(FlightSql.CommandGetSqlInfo request,
FlightProducer.CallContext context,
FlightDescriptor descriptor) |
FlightInfo |
FlightSqlProducer.getFlightInfoStatement(FlightSql.CommandStatementQuery command,
FlightProducer.CallContext context,
FlightDescriptor descriptor)
Evaluate a SQL query.
|
FlightInfo |
NoOpFlightSqlProducer.getFlightInfoStatement(FlightSql.CommandStatementQuery command,
FlightProducer.CallContext context,
FlightDescriptor descriptor) |
default FlightInfo |
FlightSqlProducer.getFlightInfoSubstraitPlan(FlightSql.CommandStatementSubstraitPlan command,
FlightProducer.CallContext context,
FlightDescriptor descriptor)
Evaluate a Substrait plan.
|
FlightInfo |
FlightSqlProducer.getFlightInfoTables(FlightSql.CommandGetTables request,
FlightProducer.CallContext context,
FlightDescriptor descriptor)
|
FlightInfo |
NoOpFlightSqlProducer.getFlightInfoTables(FlightSql.CommandGetTables request,
FlightProducer.CallContext context,
FlightDescriptor descriptor) |
FlightInfo |
BasicFlightSqlProducer.getFlightInfoTables(FlightSql.CommandGetTables request,
FlightProducer.CallContext context,
FlightDescriptor descriptor) |
FlightInfo |
FlightSqlProducer.getFlightInfoTableTypes(FlightSql.CommandGetTableTypes request,
FlightProducer.CallContext context,
FlightDescriptor descriptor)
|
FlightInfo |
NoOpFlightSqlProducer.getFlightInfoTableTypes(FlightSql.CommandGetTableTypes request,
FlightProducer.CallContext context,
FlightDescriptor descriptor) |
FlightInfo |
BasicFlightSqlProducer.getFlightInfoTableTypes(FlightSql.CommandGetTableTypes request,
FlightProducer.CallContext context,
FlightDescriptor descriptor) |
FlightInfo |
FlightSqlProducer.getFlightInfoTypeInfo(FlightSql.CommandGetXdbcTypeInfo request,
FlightProducer.CallContext context,
FlightDescriptor descriptor)
Returns a description of all the data types supported by source.
|
FlightInfo |
NoOpFlightSqlProducer.getFlightInfoTypeInfo(FlightSql.CommandGetXdbcTypeInfo request,
FlightProducer.CallContext context,
FlightDescriptor descriptor) |
FlightInfo |
BasicFlightSqlProducer.getFlightInfoTypeInfo(FlightSql.CommandGetXdbcTypeInfo request,
FlightProducer.CallContext context,
FlightDescriptor descriptor) |
default SchemaResult |
FlightSqlProducer.getSchema(FlightProducer.CallContext context,
FlightDescriptor descriptor)
Returns the schema of the result produced by the SQL query.
|
default SchemaResult |
FlightSqlProducer.getSchemaPreparedStatement(FlightSql.CommandPreparedStatementQuery command,
FlightProducer.CallContext context,
FlightDescriptor descriptor)
Get the schema of the result set of a prepared statement.
|
SchemaResult |
FlightSqlProducer.getSchemaStatement(FlightSql.CommandStatementQuery command,
FlightProducer.CallContext context,
FlightDescriptor descriptor)
Get the result schema for a SQL query.
|
SchemaResult |
NoOpFlightSqlProducer.getSchemaStatement(FlightSql.CommandStatementQuery command,
FlightProducer.CallContext context,
FlightDescriptor descriptor) |
default SchemaResult |
FlightSqlProducer.getSchemaSubstraitPlan(FlightSql.CommandStatementSubstraitPlan command,
FlightProducer.CallContext context,
FlightDescriptor descriptor)
Get the result schema for a Substrait plan.
|
default void |
FlightSqlProducer.getSessionOptions(GetSessionOptionsRequest request,
FlightProducer.CallContext context,
FlightProducer.StreamListener<GetSessionOptionsResult> listener)
Get server session option(s).
|
default void |
FlightSqlProducer.getStream(FlightProducer.CallContext context,
Ticket ticket,
FlightProducer.ServerStreamListener listener)
Depending on the provided command, method either:
1.
|
void |
FlightSqlProducer.getStreamCatalogs(FlightProducer.CallContext context,
FlightProducer.ServerStreamListener listener)
Returns data for catalogs based data stream.
|
void |
NoOpFlightSqlProducer.getStreamCatalogs(FlightProducer.CallContext context,
FlightProducer.ServerStreamListener listener) |
void |
FlightSqlProducer.getStreamCrossReference(FlightSql.CommandGetCrossReference command,
FlightProducer.CallContext context,
FlightProducer.ServerStreamListener listener)
Returns data for cross reference based data stream.
|
void |
NoOpFlightSqlProducer.getStreamCrossReference(FlightSql.CommandGetCrossReference command,
FlightProducer.CallContext context,
FlightProducer.ServerStreamListener listener) |
void |
FlightSqlProducer.getStreamExportedKeys(FlightSql.CommandGetExportedKeys command,
FlightProducer.CallContext context,
FlightProducer.ServerStreamListener listener)
Returns data for foreign keys based data stream.
|
void |
NoOpFlightSqlProducer.getStreamExportedKeys(FlightSql.CommandGetExportedKeys command,
FlightProducer.CallContext context,
FlightProducer.ServerStreamListener listener) |
void |
FlightSqlProducer.getStreamImportedKeys(FlightSql.CommandGetImportedKeys command,
FlightProducer.CallContext context,
FlightProducer.ServerStreamListener listener)
Returns data for foreign keys based data stream.
|
void |
NoOpFlightSqlProducer.getStreamImportedKeys(FlightSql.CommandGetImportedKeys command,
FlightProducer.CallContext context,
FlightProducer.ServerStreamListener listener) |
void |
FlightSqlProducer.getStreamPreparedStatement(FlightSql.CommandPreparedStatementQuery command,
FlightProducer.CallContext context,
FlightProducer.ServerStreamListener listener)
Returns data for a particular prepared statement query instance.
|
void |
NoOpFlightSqlProducer.getStreamPreparedStatement(FlightSql.CommandPreparedStatementQuery command,
FlightProducer.CallContext context,
FlightProducer.ServerStreamListener listener) |
void |
FlightSqlProducer.getStreamPrimaryKeys(FlightSql.CommandGetPrimaryKeys command,
FlightProducer.CallContext context,
FlightProducer.ServerStreamListener listener)
Returns data for primary keys based data stream.
|
void |
NoOpFlightSqlProducer.getStreamPrimaryKeys(FlightSql.CommandGetPrimaryKeys command,
FlightProducer.CallContext context,
FlightProducer.ServerStreamListener listener) |
void |
FlightSqlProducer.getStreamSchemas(FlightSql.CommandGetDbSchemas command,
FlightProducer.CallContext context,
FlightProducer.ServerStreamListener listener)
Returns data for schemas based data stream.
|
void |
NoOpFlightSqlProducer.getStreamSchemas(FlightSql.CommandGetDbSchemas command,
FlightProducer.CallContext context,
FlightProducer.ServerStreamListener listener) |
void |
FlightSqlProducer.getStreamSqlInfo(FlightSql.CommandGetSqlInfo command,
FlightProducer.CallContext context,
FlightProducer.ServerStreamListener listener)
Returns data for SQL info based data stream.
|
void |
NoOpFlightSqlProducer.getStreamSqlInfo(FlightSql.CommandGetSqlInfo command,
FlightProducer.CallContext context,
FlightProducer.ServerStreamListener listener) |
void |
FlightSqlProducer.getStreamStatement(FlightSql.TicketStatementQuery ticket,
FlightProducer.CallContext context,
FlightProducer.ServerStreamListener listener)
Returns data for a SQL query based data stream.
|
void |
NoOpFlightSqlProducer.getStreamStatement(FlightSql.TicketStatementQuery ticket,
FlightProducer.CallContext context,
FlightProducer.ServerStreamListener listener) |
void |
FlightSqlProducer.getStreamTables(FlightSql.CommandGetTables command,
FlightProducer.CallContext context,
FlightProducer.ServerStreamListener listener)
Returns data for tables based data stream.
|
void |
NoOpFlightSqlProducer.getStreamTables(FlightSql.CommandGetTables command,
FlightProducer.CallContext context,
FlightProducer.ServerStreamListener listener) |
void |
FlightSqlProducer.getStreamTableTypes(FlightProducer.CallContext context,
FlightProducer.ServerStreamListener listener)
Returns data for table types based data stream.
|
void |
NoOpFlightSqlProducer.getStreamTableTypes(FlightProducer.CallContext context,
FlightProducer.ServerStreamListener listener) |
void |
FlightSqlProducer.getStreamTypeInfo(FlightSql.CommandGetXdbcTypeInfo request,
FlightProducer.CallContext context,
FlightProducer.ServerStreamListener listener)
Returns data for type info based data stream.
|
void |
NoOpFlightSqlProducer.getStreamTypeInfo(FlightSql.CommandGetXdbcTypeInfo request,
FlightProducer.CallContext context,
FlightProducer.ServerStreamListener listener) |
default void |
FlightSqlProducer.listActions(FlightProducer.CallContext context,
FlightProducer.StreamListener<ActionType> listener)
Lists all available Flight SQL actions.
|
void |
NoOpFlightSqlProducer.listFlights(FlightProducer.CallContext context,
Criteria criteria,
FlightProducer.StreamListener<FlightInfo> listener) |
default void |
FlightSqlProducer.renewFlightEndpoint(RenewFlightEndpointRequest request,
FlightProducer.CallContext context,
FlightProducer.StreamListener<FlightEndpoint> listener)
Renew the duration of the given endpoint.
|
default void |
FlightSqlProducer.setSessionOptions(SetSessionOptionsRequest request,
FlightProducer.CallContext context,
FlightProducer.StreamListener<SetSessionOptionsResult> listener)
Set server session options(s).
|