org.apache.arrow.flight.sql

Class NoOpFlightSqlProducer

java.lang.Object

org.apache.arrow.flight.sql.NoOpFlightSqlProducer

All Implemented Interfaces:

AutoCloseable, FlightProducer, FlightSqlProducer

Direct Known Subclasses:

BasicFlightSqlProducer

public class NoOpFlightSqlProducer
extends Object
implements FlightSqlProducer

A FlightSqlProducer that throws on all FlightSql-specific operations.

Nested Class Summary

Nested classes/interfaces inherited from interface org.apache.arrow.flight.sql.FlightSqlProducer

FlightSqlProducer.Schemas

Nested classes/interfaces inherited from interface org.apache.arrow.flight.FlightProducer

FlightProducer.CallContext, FlightProducer.ServerStreamListener, FlightProducer.StreamListener<T>

Constructor Summary

Constructors

Constructor and Description
NoOpFlightSqlProducer()

Method Summary

Modifier and Type	Method and Description
Runnable	acceptPutPreparedStatementQuery(FlightSql.CommandPreparedStatementQuery command, FlightProducer.CallContext context, FlightStream flightStream, FlightProducer.StreamListener<PutResult> ackStream) Accepts uploaded parameter values for a particular prepared statement query.
Runnable	acceptPutPreparedStatementUpdate(FlightSql.CommandPreparedStatementUpdate command, FlightProducer.CallContext context, FlightStream flightStream, FlightProducer.StreamListener<PutResult> ackStream) Accepts uploaded data for a particular prepared statement data stream.
Runnable	acceptPutStatement(FlightSql.CommandStatementUpdate command, FlightProducer.CallContext context, FlightStream flightStream, FlightProducer.StreamListener<PutResult> ackStream) Accepts uploaded data for a particular SQL query based data stream.
void	close()
void	closePreparedStatement(FlightSql.ActionClosePreparedStatementRequest request, FlightProducer.CallContext context, FlightProducer.StreamListener<Result> listener) Closes a prepared statement on the server.
void	createPreparedStatement(FlightSql.ActionCreatePreparedStatementRequest request, FlightProducer.CallContext context, FlightProducer.StreamListener<Result> listener) Creates a prepared statement on the server and returns a handle and metadata for in a FlightSql.ActionCreatePreparedStatementResult object in a Result object.
FlightInfo	getFlightInfoCatalogs(FlightSql.CommandGetCatalogs request, FlightProducer.CallContext context, FlightDescriptor descriptor) Returns the available catalogs by returning a stream of FlightSql.CommandGetCatalogs objects in Result objects.
FlightInfo	getFlightInfoCrossReference(FlightSql.CommandGetCrossReference request, FlightProducer.CallContext context, FlightDescriptor descriptor) Retrieve a description of the foreign key columns that reference the given table's primary key columns FlightSql.CommandGetCrossReference objects in Result objects.
FlightInfo	getFlightInfoExportedKeys(FlightSql.CommandGetExportedKeys request, FlightProducer.CallContext context, FlightDescriptor descriptor) Retrieves a description of the foreign key columns that reference the given table's primary key columns FlightSql.CommandGetExportedKeys objects in Result objects.
FlightInfo	getFlightInfoImportedKeys(FlightSql.CommandGetImportedKeys request, FlightProducer.CallContext context, FlightDescriptor descriptor) Retrieves a description of the primary key columns that are referenced by given table's foreign key columns FlightSql.CommandGetImportedKeys objects in Result objects.
FlightInfo	getFlightInfoPreparedStatement(FlightSql.CommandPreparedStatementQuery command, FlightProducer.CallContext context, FlightDescriptor descriptor) Gets information about a particular prepared statement data stream.
FlightInfo	getFlightInfoPrimaryKeys(FlightSql.CommandGetPrimaryKeys request, FlightProducer.CallContext context, FlightDescriptor descriptor) Returns the available primary keys by returning a stream of FlightSql.CommandGetPrimaryKeys objects in Result objects.
FlightInfo	getFlightInfoSchemas(FlightSql.CommandGetDbSchemas request, FlightProducer.CallContext context, FlightDescriptor descriptor) Returns the available schemas by returning a stream of FlightSql.CommandGetDbSchemas objects in Result objects.
FlightInfo	getFlightInfoSqlInfo(FlightSql.CommandGetSqlInfo request, FlightProducer.CallContext context, FlightDescriptor descriptor) Returns the SQL Info of the server by returning a FlightSql.CommandGetSqlInfo in a Result.
FlightInfo	getFlightInfoStatement(FlightSql.CommandStatementQuery command, FlightProducer.CallContext context, FlightDescriptor descriptor) Evaluate a SQL query.
FlightInfo	getFlightInfoTables(FlightSql.CommandGetTables request, FlightProducer.CallContext context, FlightDescriptor descriptor) Returns the available tables by returning a stream of FlightSql.CommandGetTables objects in Result objects.
FlightInfo	getFlightInfoTableTypes(FlightSql.CommandGetTableTypes request, FlightProducer.CallContext context, FlightDescriptor descriptor) Returns the available table types by returning a stream of FlightSql.CommandGetTableTypes objects in Result objects.
FlightInfo	getFlightInfoTypeInfo(FlightSql.CommandGetXdbcTypeInfo request, FlightProducer.CallContext context, FlightDescriptor descriptor) Returns a description of all the data types supported by source.
SchemaResult	getSchemaStatement(FlightSql.CommandStatementQuery command, FlightProducer.CallContext context, FlightDescriptor descriptor) Get the result schema for a SQL query.
void	getStreamCatalogs(FlightProducer.CallContext context, FlightProducer.ServerStreamListener listener) Returns data for catalogs based data stream.
void	getStreamCrossReference(FlightSql.CommandGetCrossReference command, FlightProducer.CallContext context, FlightProducer.ServerStreamListener listener) Returns data for cross reference based data stream.
void	getStreamExportedKeys(FlightSql.CommandGetExportedKeys command, FlightProducer.CallContext context, FlightProducer.ServerStreamListener listener) Returns data for foreign keys based data stream.
void	getStreamImportedKeys(FlightSql.CommandGetImportedKeys command, FlightProducer.CallContext context, FlightProducer.ServerStreamListener listener) Returns data for foreign keys based data stream.
void	getStreamPreparedStatement(FlightSql.CommandPreparedStatementQuery command, FlightProducer.CallContext context, FlightProducer.ServerStreamListener listener) Returns data for a particular prepared statement query instance.
void	getStreamPrimaryKeys(FlightSql.CommandGetPrimaryKeys command, FlightProducer.CallContext context, FlightProducer.ServerStreamListener listener) Returns data for primary keys based data stream.
void	getStreamSchemas(FlightSql.CommandGetDbSchemas command, FlightProducer.CallContext context, FlightProducer.ServerStreamListener listener) Returns data for schemas based data stream.
void	getStreamSqlInfo(FlightSql.CommandGetSqlInfo command, FlightProducer.CallContext context, FlightProducer.ServerStreamListener listener) Returns data for SQL info based data stream.
void	getStreamStatement(FlightSql.TicketStatementQuery ticket, FlightProducer.CallContext context, FlightProducer.ServerStreamListener listener) Returns data for a SQL query based data stream.
void	getStreamTables(FlightSql.CommandGetTables command, FlightProducer.CallContext context, FlightProducer.ServerStreamListener listener) Returns data for tables based data stream.
void	getStreamTableTypes(FlightProducer.CallContext context, FlightProducer.ServerStreamListener listener) Returns data for table types based data stream.
void	getStreamTypeInfo(FlightSql.CommandGetXdbcTypeInfo request, FlightProducer.CallContext context, FlightProducer.ServerStreamListener listener) Returns data for type info based data stream.
void	listFlights(FlightProducer.CallContext context, Criteria criteria, FlightProducer.StreamListener<FlightInfo> listener) List available data streams on this service.

Methods inherited from class java.lang.Object

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

Methods inherited from interface org.apache.arrow.flight.sql.FlightSqlProducer

acceptPut, acceptPutSubstraitPlan, beginSavepoint, beginTransaction, cancelFlightInfo, cancelQuery, closeSession, createPreparedSubstraitPlan, doAction, endSavepoint, endTransaction, getFlightInfo, getFlightInfoSubstraitPlan, getSchema, getSchemaPreparedStatement, getSchemaSubstraitPlan, getSessionOptions, getStream, listActions, renewFlightEndpoint, setSessionOptions

Methods inherited from interface org.apache.arrow.flight.FlightProducer

doExchange, pollFlightInfo

Constructor Detail

NoOpFlightSqlProducer

public NoOpFlightSqlProducer()

Method Detail

createPreparedStatement

public void createPreparedStatement(FlightSql.ActionCreatePreparedStatementRequest request,
                                    FlightProducer.CallContext context,
                                    FlightProducer.StreamListener<Result> listener)

Description copied from interface: FlightSqlProducer

Creates a prepared statement on the server and returns a handle and metadata for in a FlightSql.ActionCreatePreparedStatementResult object in a Result object.

Specified by:

createPreparedStatement in interface FlightSqlProducer

Parameters:

request - The sql command to generate the prepared statement.

context - Per-call context.

listener - A stream of responses.

closePreparedStatement

public void closePreparedStatement(FlightSql.ActionClosePreparedStatementRequest request,
                                   FlightProducer.CallContext context,
                                   FlightProducer.StreamListener<Result> listener)

Description copied from interface: FlightSqlProducer

Closes a prepared statement on the server. No result is expected.

Specified by:

closePreparedStatement in interface FlightSqlProducer

Parameters:

request - The sql command to generate the prepared statement.

context - Per-call context.

listener - A stream of responses.

getFlightInfoStatement

public FlightInfo getFlightInfoStatement(FlightSql.CommandStatementQuery command,
                                         FlightProducer.CallContext context,
                                         FlightDescriptor descriptor)

Description copied from interface: FlightSqlProducer

Evaluate a SQL query.

Specified by:

getFlightInfoStatement in interface FlightSqlProducer

Parameters:

command - The SQL query.

context - Per-call context.

descriptor - The descriptor identifying the data stream.

Returns:

Metadata about the stream.

getFlightInfoPreparedStatement

public FlightInfo getFlightInfoPreparedStatement(FlightSql.CommandPreparedStatementQuery command,
                                                 FlightProducer.CallContext context,
                                                 FlightDescriptor descriptor)

Description copied from interface: FlightSqlProducer

Gets information about a particular prepared statement data stream.

Specified by:

getFlightInfoPreparedStatement in interface FlightSqlProducer

Parameters:

command - The prepared statement to generate the data stream.

context - Per-call context.

descriptor - The descriptor identifying the data stream.

Returns:

Metadata about the stream.

getSchemaStatement

public SchemaResult getSchemaStatement(FlightSql.CommandStatementQuery command,
                                       FlightProducer.CallContext context,
                                       FlightDescriptor descriptor)

Description copied from interface: FlightSqlProducer

Get the result schema for a SQL query.

Specified by:

getSchemaStatement in interface FlightSqlProducer

Parameters:

command - The SQL query.

context - Per-call context.

descriptor - The descriptor identifying the data stream.

Returns:

the schema of the result set.

getStreamStatement

public void getStreamStatement(FlightSql.TicketStatementQuery ticket,
                               FlightProducer.CallContext context,
                               FlightProducer.ServerStreamListener listener)

Description copied from interface: FlightSqlProducer

Returns data for a SQL query based data stream.

Specified by:

getStreamStatement in interface FlightSqlProducer

Parameters:

ticket - Ticket message containing the statement handle.

context - Per-call context.

listener - An interface for sending data back to the client.

getStreamPreparedStatement

public void getStreamPreparedStatement(FlightSql.CommandPreparedStatementQuery command,
                                       FlightProducer.CallContext context,
                                       FlightProducer.ServerStreamListener listener)

Description copied from interface: FlightSqlProducer

Returns data for a particular prepared statement query instance.

Specified by:

getStreamPreparedStatement in interface FlightSqlProducer

Parameters:

command - The prepared statement to generate the data stream.

context - Per-call context.

listener - An interface for sending data back to the client.

acceptPutStatement

public Runnable acceptPutStatement(FlightSql.CommandStatementUpdate command,
                                   FlightProducer.CallContext context,
                                   FlightStream flightStream,
                                   FlightProducer.StreamListener<PutResult> ackStream)

Description copied from interface: FlightSqlProducer

Accepts uploaded data for a particular SQL query based data stream.

`PutResult`s must be in the form of a FlightSql.DoPutUpdateResult.

Specified by:

acceptPutStatement in interface FlightSqlProducer

Parameters:

command - The sql command to generate the data stream.

context - Per-call context.

flightStream - The data stream being uploaded.

ackStream - The result data stream.

Returns:

A runnable to process the stream.

acceptPutPreparedStatementUpdate

public Runnable acceptPutPreparedStatementUpdate(FlightSql.CommandPreparedStatementUpdate command,
                                                 FlightProducer.CallContext context,
                                                 FlightStream flightStream,
                                                 FlightProducer.StreamListener<PutResult> ackStream)

Description copied from interface: FlightSqlProducer

Accepts uploaded data for a particular prepared statement data stream.

`PutResult`s must be in the form of a FlightSql.DoPutUpdateResult.

Specified by:

acceptPutPreparedStatementUpdate in interface FlightSqlProducer

Parameters:

command - The prepared statement to generate the data stream.

context - Per-call context.

flightStream - The data stream being uploaded.

ackStream - The result data stream.

Returns:

A runnable to process the stream.

acceptPutPreparedStatementQuery

public Runnable acceptPutPreparedStatementQuery(FlightSql.CommandPreparedStatementQuery command,
                                                FlightProducer.CallContext context,
                                                FlightStream flightStream,
                                                FlightProducer.StreamListener<PutResult> ackStream)

Description copied from interface: FlightSqlProducer

Accepts uploaded parameter values for a particular prepared statement query.

Specified by:

acceptPutPreparedStatementQuery in interface FlightSqlProducer

Parameters:

command - The prepared statement the parameter values will bind to.

context - Per-call context.

flightStream - The data stream being uploaded.

ackStream - The result data stream.

Returns:

A runnable to process the stream.

getFlightInfoSqlInfo

public FlightInfo getFlightInfoSqlInfo(FlightSql.CommandGetSqlInfo request,
                                       FlightProducer.CallContext context,
                                       FlightDescriptor descriptor)

Description copied from interface: FlightSqlProducer

Returns the SQL Info of the server by returning a FlightSql.CommandGetSqlInfo in a Result.

Specified by:

getFlightInfoSqlInfo in interface FlightSqlProducer

Parameters:

request - request filter parameters.

context - Per-call context.

descriptor - The descriptor identifying the data stream.

Returns:

Metadata about the stream.

getStreamSqlInfo

public void getStreamSqlInfo(FlightSql.CommandGetSqlInfo command,
                             FlightProducer.CallContext context,
                             FlightProducer.ServerStreamListener listener)

Description copied from interface: FlightSqlProducer

Returns data for SQL info based data stream.

Specified by:

getStreamSqlInfo in interface FlightSqlProducer

Parameters:

command - The command to generate the data stream.

context - Per-call context.

listener - An interface for sending data back to the client.

getFlightInfoTypeInfo

public FlightInfo getFlightInfoTypeInfo(FlightSql.CommandGetXdbcTypeInfo request,
                                        FlightProducer.CallContext context,
                                        FlightDescriptor descriptor)

Description copied from interface: FlightSqlProducer

Returns a description of all the data types supported by source.

Specified by:

getFlightInfoTypeInfo in interface FlightSqlProducer

Parameters:

request - request filter parameters.

descriptor - The descriptor identifying the data stream.

Returns:

Metadata about the stream.

getStreamTypeInfo

public void getStreamTypeInfo(FlightSql.CommandGetXdbcTypeInfo request,
                              FlightProducer.CallContext context,
                              FlightProducer.ServerStreamListener listener)

Description copied from interface: FlightSqlProducer

Returns data for type info based data stream.

Specified by:

getStreamTypeInfo in interface FlightSqlProducer

context - Per-call context.

listener - An interface for sending data back to the client.

getFlightInfoCatalogs

public FlightInfo getFlightInfoCatalogs(FlightSql.CommandGetCatalogs request,
                                        FlightProducer.CallContext context,
                                        FlightDescriptor descriptor)

Description copied from interface: FlightSqlProducer

Returns the available catalogs by returning a stream of FlightSql.CommandGetCatalogs objects in Result objects.

Specified by:

getFlightInfoCatalogs in interface FlightSqlProducer

Parameters:

request - request filter parameters.

context - Per-call context.

descriptor - The descriptor identifying the data stream.

Returns:

Metadata about the stream.

getStreamCatalogs

public void getStreamCatalogs(FlightProducer.CallContext context,
                              FlightProducer.ServerStreamListener listener)

Description copied from interface: FlightSqlProducer

Returns data for catalogs based data stream.

Specified by:

getStreamCatalogs in interface FlightSqlProducer

Parameters:

context - Per-call context.

listener - An interface for sending data back to the client.

getFlightInfoSchemas

public FlightInfo getFlightInfoSchemas(FlightSql.CommandGetDbSchemas request,
                                       FlightProducer.CallContext context,
                                       FlightDescriptor descriptor)

Description copied from interface: FlightSqlProducer

Returns the available schemas by returning a stream of FlightSql.CommandGetDbSchemas objects in Result objects.

Specified by:

getFlightInfoSchemas in interface FlightSqlProducer

Parameters:

request - request filter parameters.

context - Per-call context.

descriptor - The descriptor identifying the data stream.

Returns:

Metadata about the stream.

getStreamSchemas

public void getStreamSchemas(FlightSql.CommandGetDbSchemas command,
                             FlightProducer.CallContext context,
                             FlightProducer.ServerStreamListener listener)

Description copied from interface: FlightSqlProducer

Returns data for schemas based data stream.

Specified by:

getStreamSchemas in interface FlightSqlProducer

Parameters:

command - The command to generate the data stream.

context - Per-call context.

listener - An interface for sending data back to the client.

getFlightInfoTables

public FlightInfo getFlightInfoTables(FlightSql.CommandGetTables request,
                                      FlightProducer.CallContext context,
                                      FlightDescriptor descriptor)

Description copied from interface: FlightSqlProducer

Returns the available tables by returning a stream of FlightSql.CommandGetTables objects in Result objects.

Specified by:

getFlightInfoTables in interface FlightSqlProducer

Parameters:

request - request filter parameters.

context - Per-call context.

descriptor - The descriptor identifying the data stream.

Returns:

Metadata about the stream.

getStreamTables

public void getStreamTables(FlightSql.CommandGetTables command,
                            FlightProducer.CallContext context,
                            FlightProducer.ServerStreamListener listener)

Description copied from interface: FlightSqlProducer

Returns data for tables based data stream.

Specified by:

getStreamTables in interface FlightSqlProducer

Parameters:

command - The command to generate the data stream.

context - Per-call context.

listener - An interface for sending data back to the client.

getFlightInfoTableTypes

public FlightInfo getFlightInfoTableTypes(FlightSql.CommandGetTableTypes request,
                                          FlightProducer.CallContext context,
                                          FlightDescriptor descriptor)

Description copied from interface: FlightSqlProducer

Returns the available table types by returning a stream of FlightSql.CommandGetTableTypes objects in Result objects.

Specified by:

getFlightInfoTableTypes in interface FlightSqlProducer

context - Per-call context.

descriptor - The descriptor identifying the data stream.

Returns:

Metadata about the stream.

getStreamTableTypes

public void getStreamTableTypes(FlightProducer.CallContext context,
                                FlightProducer.ServerStreamListener listener)

Description copied from interface: FlightSqlProducer

Returns data for table types based data stream.

Specified by:

getStreamTableTypes in interface FlightSqlProducer

Parameters:

context - Per-call context.

listener - An interface for sending data back to the client.

getFlightInfoPrimaryKeys

public FlightInfo getFlightInfoPrimaryKeys(FlightSql.CommandGetPrimaryKeys request,
                                           FlightProducer.CallContext context,
                                           FlightDescriptor descriptor)

Description copied from interface: FlightSqlProducer

Returns the available primary keys by returning a stream of FlightSql.CommandGetPrimaryKeys objects in Result objects.

Specified by:

getFlightInfoPrimaryKeys in interface FlightSqlProducer

Parameters:

request - request filter parameters.

context - Per-call context.

descriptor - The descriptor identifying the data stream.

Returns:

Metadata about the stream.

getStreamPrimaryKeys

public void getStreamPrimaryKeys(FlightSql.CommandGetPrimaryKeys command,
                                 FlightProducer.CallContext context,
                                 FlightProducer.ServerStreamListener listener)

Description copied from interface: FlightSqlProducer

Returns data for primary keys based data stream.

Specified by:

getStreamPrimaryKeys in interface FlightSqlProducer

Parameters:

command - The command to generate the data stream.

context - Per-call context.

listener - An interface for sending data back to the client.

getFlightInfoExportedKeys

public FlightInfo getFlightInfoExportedKeys(FlightSql.CommandGetExportedKeys request,
                                            FlightProducer.CallContext context,
                                            FlightDescriptor descriptor)

Description copied from interface: FlightSqlProducer

Retrieves a description of the foreign key columns that reference the given table's primary key columns FlightSql.CommandGetExportedKeys objects in Result objects.

Specified by:

getFlightInfoExportedKeys in interface FlightSqlProducer

Parameters:

request - request filter parameters.

context - Per-call context.

descriptor - The descriptor identifying the data stream.

Returns:

Metadata about the stream.

getFlightInfoImportedKeys

public FlightInfo getFlightInfoImportedKeys(FlightSql.CommandGetImportedKeys request,
                                            FlightProducer.CallContext context,
                                            FlightDescriptor descriptor)

Description copied from interface: FlightSqlProducer

Retrieves a description of the primary key columns that are referenced by given table's foreign key columns FlightSql.CommandGetImportedKeys objects in Result objects.

Specified by:

getFlightInfoImportedKeys in interface FlightSqlProducer

Parameters:

request - request filter parameters.

context - Per-call context.

descriptor - The descriptor identifying the data stream.

Returns:

Metadata about the stream.

getFlightInfoCrossReference

public FlightInfo getFlightInfoCrossReference(FlightSql.CommandGetCrossReference request,
                                              FlightProducer.CallContext context,
                                              FlightDescriptor descriptor)

Description copied from interface: FlightSqlProducer

Retrieve a description of the foreign key columns that reference the given table's primary key columns FlightSql.CommandGetCrossReference objects in Result objects.

Specified by:

getFlightInfoCrossReference in interface FlightSqlProducer

Parameters:

request - request filter parameters.

context - Per-call context.

descriptor - The descriptor identifying the data stream.

Returns:

Metadata about the stream.

getStreamExportedKeys

public void getStreamExportedKeys(FlightSql.CommandGetExportedKeys command,
                                  FlightProducer.CallContext context,
                                  FlightProducer.ServerStreamListener listener)

Description copied from interface: FlightSqlProducer

Returns data for foreign keys based data stream.

Specified by:

getStreamExportedKeys in interface FlightSqlProducer

Parameters:

command - The command to generate the data stream.

context - Per-call context.

listener - An interface for sending data back to the client.

getStreamImportedKeys

public void getStreamImportedKeys(FlightSql.CommandGetImportedKeys command,
                                  FlightProducer.CallContext context,
                                  FlightProducer.ServerStreamListener listener)

Description copied from interface: FlightSqlProducer

Returns data for foreign keys based data stream.

Specified by:

getStreamImportedKeys in interface FlightSqlProducer

Parameters:

command - The command to generate the data stream.

context - Per-call context.

listener - An interface for sending data back to the client.

getStreamCrossReference

public void getStreamCrossReference(FlightSql.CommandGetCrossReference command,
                                    FlightProducer.CallContext context,
                                    FlightProducer.ServerStreamListener listener)

Description copied from interface: FlightSqlProducer

Returns data for cross reference based data stream.

Specified by:

getStreamCrossReference in interface FlightSqlProducer

Parameters:

command - The command to generate the data stream.

context - Per-call context.

listener - An interface for sending data back to the client.

close

public void close()
           throws Exception

Specified by:

close in interface AutoCloseable

Throws:

Exception

listFlights

public void listFlights(FlightProducer.CallContext context,
                        Criteria criteria,
                        FlightProducer.StreamListener<FlightInfo> listener)

Description copied from interface: FlightProducer

List available data streams on this service.

Specified by:

listFlights in interface FlightProducer

Parameters:

context - Per-call context.

criteria - Application-defined criteria for filtering streams.

listener - An interface for sending data back to the client.