public abstract class BasicFlightSqlProducer extends NoOpFlightSqlProducer
FlightSqlProducer
that implements getting FlightInfo for each metadata request.FlightSqlProducer.Schemas
FlightProducer.CallContext, FlightProducer.ServerStreamListener, FlightProducer.StreamListener<T>
Constructor and Description |
---|
BasicFlightSqlProducer() |
Modifier and Type | Method and Description |
---|---|
protected abstract <T extends com.google.protobuf.Message> |
determineEndpoints(T request,
FlightDescriptor flightDescriptor,
Schema schema)
Return a list of FlightEndpoints for the given request and FlightDescriptor.
|
protected <T extends com.google.protobuf.Message> |
generateFlightInfo(T request,
FlightDescriptor descriptor,
Schema schema) |
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 |
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 |
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.
|
acceptPutPreparedStatementQuery, acceptPutPreparedStatementUpdate, acceptPutStatement, close, closePreparedStatement, createPreparedStatement, getFlightInfoPreparedStatement, getFlightInfoStatement, getSchemaStatement, getStreamCatalogs, getStreamCrossReference, getStreamExportedKeys, getStreamImportedKeys, getStreamPreparedStatement, getStreamPrimaryKeys, getStreamSchemas, getStreamSqlInfo, getStreamStatement, getStreamTables, getStreamTableTypes, getStreamTypeInfo, listFlights
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
acceptPut, acceptPutSubstraitPlan, beginSavepoint, beginTransaction, cancelFlightInfo, cancelQuery, closeSession, createPreparedSubstraitPlan, doAction, endSavepoint, endTransaction, getFlightInfo, getFlightInfoSubstraitPlan, getSchema, getSchemaPreparedStatement, getSchemaSubstraitPlan, getSessionOptions, getStream, listActions, renewFlightEndpoint, setSessionOptions
doExchange, pollFlightInfo
public FlightInfo getFlightInfoSqlInfo(FlightSql.CommandGetSqlInfo request, FlightProducer.CallContext context, FlightDescriptor descriptor)
FlightSqlProducer
FlightSql.CommandGetSqlInfo
in a Result
.getFlightInfoSqlInfo
in interface FlightSqlProducer
getFlightInfoSqlInfo
in class NoOpFlightSqlProducer
request
- request filter parameters.context
- Per-call context.descriptor
- The descriptor identifying the data stream.public FlightInfo getFlightInfoTypeInfo(FlightSql.CommandGetXdbcTypeInfo request, FlightProducer.CallContext context, FlightDescriptor descriptor)
FlightSqlProducer
getFlightInfoTypeInfo
in interface FlightSqlProducer
getFlightInfoTypeInfo
in class NoOpFlightSqlProducer
request
- request filter parameters.descriptor
- The descriptor identifying the data stream.public FlightInfo getFlightInfoCatalogs(FlightSql.CommandGetCatalogs request, FlightProducer.CallContext context, FlightDescriptor descriptor)
FlightSqlProducer
FlightSql.CommandGetCatalogs
objects in Result
objects.getFlightInfoCatalogs
in interface FlightSqlProducer
getFlightInfoCatalogs
in class NoOpFlightSqlProducer
request
- request filter parameters.context
- Per-call context.descriptor
- The descriptor identifying the data stream.public FlightInfo getFlightInfoSchemas(FlightSql.CommandGetDbSchemas request, FlightProducer.CallContext context, FlightDescriptor descriptor)
FlightSqlProducer
FlightSql.CommandGetDbSchemas
objects in Result
objects.getFlightInfoSchemas
in interface FlightSqlProducer
getFlightInfoSchemas
in class NoOpFlightSqlProducer
request
- request filter parameters.context
- Per-call context.descriptor
- The descriptor identifying the data stream.public FlightInfo getFlightInfoTables(FlightSql.CommandGetTables request, FlightProducer.CallContext context, FlightDescriptor descriptor)
FlightSqlProducer
FlightSql.CommandGetTables
objects in Result
objects.getFlightInfoTables
in interface FlightSqlProducer
getFlightInfoTables
in class NoOpFlightSqlProducer
request
- request filter parameters.context
- Per-call context.descriptor
- The descriptor identifying the data stream.public FlightInfo getFlightInfoTableTypes(FlightSql.CommandGetTableTypes request, FlightProducer.CallContext context, FlightDescriptor descriptor)
FlightSqlProducer
FlightSql.CommandGetTableTypes
objects in Result
objects.getFlightInfoTableTypes
in interface FlightSqlProducer
getFlightInfoTableTypes
in class NoOpFlightSqlProducer
context
- Per-call context.descriptor
- The descriptor identifying the data stream.public FlightInfo getFlightInfoPrimaryKeys(FlightSql.CommandGetPrimaryKeys request, FlightProducer.CallContext context, FlightDescriptor descriptor)
FlightSqlProducer
FlightSql.CommandGetPrimaryKeys
objects in Result
objects.getFlightInfoPrimaryKeys
in interface FlightSqlProducer
getFlightInfoPrimaryKeys
in class NoOpFlightSqlProducer
request
- request filter parameters.context
- Per-call context.descriptor
- The descriptor identifying the data stream.public FlightInfo getFlightInfoExportedKeys(FlightSql.CommandGetExportedKeys request, FlightProducer.CallContext context, FlightDescriptor descriptor)
FlightSqlProducer
FlightSql.CommandGetExportedKeys
objects in Result
objects.getFlightInfoExportedKeys
in interface FlightSqlProducer
getFlightInfoExportedKeys
in class NoOpFlightSqlProducer
request
- request filter parameters.context
- Per-call context.descriptor
- The descriptor identifying the data stream.public FlightInfo getFlightInfoImportedKeys(FlightSql.CommandGetImportedKeys request, FlightProducer.CallContext context, FlightDescriptor descriptor)
FlightSqlProducer
FlightSql.CommandGetImportedKeys
objects in Result
objects.getFlightInfoImportedKeys
in interface FlightSqlProducer
getFlightInfoImportedKeys
in class NoOpFlightSqlProducer
request
- request filter parameters.context
- Per-call context.descriptor
- The descriptor identifying the data stream.public FlightInfo getFlightInfoCrossReference(FlightSql.CommandGetCrossReference request, FlightProducer.CallContext context, FlightDescriptor descriptor)
FlightSqlProducer
FlightSql.CommandGetCrossReference
objects in Result
objects.getFlightInfoCrossReference
in interface FlightSqlProducer
getFlightInfoCrossReference
in class NoOpFlightSqlProducer
request
- request filter parameters.context
- Per-call context.descriptor
- The descriptor identifying the data stream.protected abstract <T extends com.google.protobuf.Message> List<FlightEndpoint> determineEndpoints(T request, FlightDescriptor flightDescriptor, Schema schema)
protected <T extends com.google.protobuf.Message> FlightInfo generateFlightInfo(T request, FlightDescriptor descriptor, Schema schema)
Copyright © 2024 The Apache Software Foundation. All rights reserved.