Uses of Class
org.apache.arrow.flight.FlightDescriptor
Packages that use FlightDescriptor
-
Uses of FlightDescriptor in org.apache.arrow.flight
Methods in org.apache.arrow.flight that return FlightDescriptorModifier and TypeMethodDescriptionstatic FlightDescriptorFlightDescriptor.command(byte[] cmd) static FlightDescriptorFlightDescriptor.deserialize(ByteBuffer serialized) Parse the serialized form of this protocol message.FlightInfo.getDescriptor()FlightStream.getDescriptor()Get the descriptor for this stream.static FlightDescriptorstatic FlightDescriptorMethods in org.apache.arrow.flight that return types with arguments of type FlightDescriptorModifier and TypeMethodDescriptionPollInfo.getFlightDescriptor()The FlightDescriptor that should be used to get further updates on this query.Methods in org.apache.arrow.flight with parameters of type FlightDescriptorModifier and TypeMethodDescriptionstatic FlightInfo.BuilderFlightInfo.builder(Schema schema, FlightDescriptor descriptor, List<FlightEndpoint> endpoints) Create a builder for FlightInfo.FlightClient.doExchange(FlightDescriptor descriptor, CallOption... options) Initiate a bidirectional data exchange with the server.FlightProducer.getFlightInfo(FlightProducer.CallContext context, FlightDescriptor descriptor) Get information about a particular data stream.NoOpFlightProducer.getFlightInfo(FlightProducer.CallContext context, FlightDescriptor descriptor) FlightClient.getInfo(FlightDescriptor descriptor, CallOption... options) Get info on a stream.FlightClient.getSchema(FlightDescriptor descriptor, CallOption... options) Get schema for a stream.default SchemaResultFlightProducer.getSchema(FlightProducer.CallContext context, FlightDescriptor descriptor) Get schema for a particular data stream.default PollInfoFlightProducer.pollFlightInfo(FlightProducer.CallContext context, FlightDescriptor descriptor) Begin or get an update on execution of a long-running query.FlightClient.pollInfo(FlightDescriptor descriptor, CallOption... options) Start or get info on execution of a long-running query.FlightClient.startPut(FlightDescriptor descriptor, FlightClient.PutListener metadataListener, CallOption... options) Create or append a descriptor with another stream.FlightClient.startPut(FlightDescriptor descriptor, VectorSchemaRoot root, FlightClient.PutListener metadataListener, CallOption... options) Create or append a descriptor with another stream.FlightClient.startPut(FlightDescriptor descriptor, VectorSchemaRoot root, DictionaryProvider provider, FlightClient.PutListener metadataListener, CallOption... options) Create or append a descriptor with another stream.Constructors in org.apache.arrow.flight with parameters of type FlightDescriptorModifierConstructorDescriptionFlightInfo(Schema schema, FlightDescriptor descriptor, List<FlightEndpoint> endpoints, long bytes, long records) Constructs a new instance.FlightInfo(Schema schema, FlightDescriptor descriptor, List<FlightEndpoint> endpoints, long bytes, long records, boolean ordered, IpcOption option) Constructs a new instance.FlightInfo(Schema schema, FlightDescriptor descriptor, List<FlightEndpoint> endpoints, long bytes, long records, boolean ordered, IpcOption option, byte[] appMetadata) Constructs a new instance.FlightInfo(Schema schema, FlightDescriptor descriptor, List<FlightEndpoint> endpoints, long bytes, long records, IpcOption option) Constructs a new instance.PollInfo(FlightInfo flightInfo, FlightDescriptor flightDescriptor, Double progress, Instant expirationTime) Create a new PollInfo. -
Uses of FlightDescriptor in org.apache.arrow.flight.sql
Methods in org.apache.arrow.flight.sql with parameters of type FlightDescriptorModifier and TypeMethodDescriptionprotected abstract <T extends com.google.protobuf.Message>
List<FlightEndpoint>BasicFlightSqlProducer.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>
FlightInfoBasicFlightSqlProducer.generateFlightInfo(T request, FlightDescriptor descriptor, Schema schema) default FlightInfoFlightSqlProducer.getFlightInfo(FlightProducer.CallContext context, FlightDescriptor descriptor) Depending on the provided command, method either: 1.BasicFlightSqlProducer.getFlightInfoCatalogs(FlightSql.CommandGetCatalogs request, FlightProducer.CallContext context, FlightDescriptor descriptor) FlightSqlProducer.getFlightInfoCatalogs(FlightSql.CommandGetCatalogs request, FlightProducer.CallContext context, FlightDescriptor descriptor) Returns the available catalogs by returning a stream ofFlightSql.CommandGetCatalogsobjects inResultobjects.NoOpFlightSqlProducer.getFlightInfoCatalogs(FlightSql.CommandGetCatalogs request, FlightProducer.CallContext context, FlightDescriptor descriptor) BasicFlightSqlProducer.getFlightInfoCrossReference(FlightSql.CommandGetCrossReference request, FlightProducer.CallContext context, FlightDescriptor descriptor) FlightSqlProducer.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 columnsFlightSql.CommandGetCrossReferenceobjects inResultobjects.NoOpFlightSqlProducer.getFlightInfoCrossReference(FlightSql.CommandGetCrossReference request, FlightProducer.CallContext context, FlightDescriptor descriptor) BasicFlightSqlProducer.getFlightInfoExportedKeys(FlightSql.CommandGetExportedKeys request, FlightProducer.CallContext context, FlightDescriptor descriptor) FlightSqlProducer.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 columnsFlightSql.CommandGetExportedKeysobjects inResultobjects.NoOpFlightSqlProducer.getFlightInfoExportedKeys(FlightSql.CommandGetExportedKeys request, FlightProducer.CallContext context, FlightDescriptor descriptor) BasicFlightSqlProducer.getFlightInfoImportedKeys(FlightSql.CommandGetImportedKeys request, FlightProducer.CallContext context, FlightDescriptor descriptor) FlightSqlProducer.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 columnsFlightSql.CommandGetImportedKeysobjects inResultobjects.NoOpFlightSqlProducer.getFlightInfoImportedKeys(FlightSql.CommandGetImportedKeys request, FlightProducer.CallContext context, FlightDescriptor descriptor) FlightSqlProducer.getFlightInfoPreparedStatement(FlightSql.CommandPreparedStatementQuery command, FlightProducer.CallContext context, FlightDescriptor descriptor) Gets information about a particular prepared statement data stream.NoOpFlightSqlProducer.getFlightInfoPreparedStatement(FlightSql.CommandPreparedStatementQuery command, FlightProducer.CallContext context, FlightDescriptor descriptor) BasicFlightSqlProducer.getFlightInfoPrimaryKeys(FlightSql.CommandGetPrimaryKeys request, FlightProducer.CallContext context, FlightDescriptor descriptor) FlightSqlProducer.getFlightInfoPrimaryKeys(FlightSql.CommandGetPrimaryKeys request, FlightProducer.CallContext context, FlightDescriptor descriptor) Returns the available primary keys by returning a stream ofFlightSql.CommandGetPrimaryKeysobjects inResultobjects.NoOpFlightSqlProducer.getFlightInfoPrimaryKeys(FlightSql.CommandGetPrimaryKeys request, FlightProducer.CallContext context, FlightDescriptor descriptor) BasicFlightSqlProducer.getFlightInfoSchemas(FlightSql.CommandGetDbSchemas request, FlightProducer.CallContext context, FlightDescriptor descriptor) FlightSqlProducer.getFlightInfoSchemas(FlightSql.CommandGetDbSchemas request, FlightProducer.CallContext context, FlightDescriptor descriptor) Returns the available schemas by returning a stream ofFlightSql.CommandGetDbSchemasobjects inResultobjects.NoOpFlightSqlProducer.getFlightInfoSchemas(FlightSql.CommandGetDbSchemas request, FlightProducer.CallContext context, FlightDescriptor descriptor) BasicFlightSqlProducer.getFlightInfoSqlInfo(FlightSql.CommandGetSqlInfo request, FlightProducer.CallContext context, FlightDescriptor descriptor) FlightSqlProducer.getFlightInfoSqlInfo(FlightSql.CommandGetSqlInfo request, FlightProducer.CallContext context, FlightDescriptor descriptor) Returns the SQL Info of the server by returning aFlightSql.CommandGetSqlInfoin aResult.NoOpFlightSqlProducer.getFlightInfoSqlInfo(FlightSql.CommandGetSqlInfo request, FlightProducer.CallContext context, FlightDescriptor descriptor) FlightSqlProducer.getFlightInfoStatement(FlightSql.CommandStatementQuery command, FlightProducer.CallContext context, FlightDescriptor descriptor) Evaluate a SQL query.NoOpFlightSqlProducer.getFlightInfoStatement(FlightSql.CommandStatementQuery command, FlightProducer.CallContext context, FlightDescriptor descriptor) default FlightInfoFlightSqlProducer.getFlightInfoSubstraitPlan(FlightSql.CommandStatementSubstraitPlan command, FlightProducer.CallContext context, FlightDescriptor descriptor) Evaluate a Substrait plan.BasicFlightSqlProducer.getFlightInfoTables(FlightSql.CommandGetTables request, FlightProducer.CallContext context, FlightDescriptor descriptor) FlightSqlProducer.getFlightInfoTables(FlightSql.CommandGetTables request, FlightProducer.CallContext context, FlightDescriptor descriptor) Returns the available tables by returning a stream ofFlightSql.CommandGetTablesobjects inResultobjects.NoOpFlightSqlProducer.getFlightInfoTables(FlightSql.CommandGetTables request, FlightProducer.CallContext context, FlightDescriptor descriptor) BasicFlightSqlProducer.getFlightInfoTableTypes(FlightSql.CommandGetTableTypes request, FlightProducer.CallContext context, FlightDescriptor descriptor) FlightSqlProducer.getFlightInfoTableTypes(FlightSql.CommandGetTableTypes request, FlightProducer.CallContext context, FlightDescriptor descriptor) Returns the available table types by returning a stream ofFlightSql.CommandGetTableTypesobjects inResultobjects.NoOpFlightSqlProducer.getFlightInfoTableTypes(FlightSql.CommandGetTableTypes request, FlightProducer.CallContext context, FlightDescriptor descriptor) BasicFlightSqlProducer.getFlightInfoTypeInfo(FlightSql.CommandGetXdbcTypeInfo request, FlightProducer.CallContext context, FlightDescriptor descriptor) FlightSqlProducer.getFlightInfoTypeInfo(FlightSql.CommandGetXdbcTypeInfo request, FlightProducer.CallContext context, FlightDescriptor descriptor) Returns a description of all the data types supported by source.NoOpFlightSqlProducer.getFlightInfoTypeInfo(FlightSql.CommandGetXdbcTypeInfo request, FlightProducer.CallContext context, FlightDescriptor descriptor) FlightSqlClient.getSchema(FlightDescriptor descriptor, CallOption... options) Get schema for a stream.default SchemaResultFlightSqlProducer.getSchema(FlightProducer.CallContext context, FlightDescriptor descriptor) Returns the schema of the result produced by the SQL query.default SchemaResultFlightSqlProducer.getSchemaPreparedStatement(FlightSql.CommandPreparedStatementQuery command, FlightProducer.CallContext context, FlightDescriptor descriptor) Get the schema of the result set of a prepared statement.FlightSqlProducer.getSchemaStatement(FlightSql.CommandStatementQuery command, FlightProducer.CallContext context, FlightDescriptor descriptor) Get the result schema for a SQL query.NoOpFlightSqlProducer.getSchemaStatement(FlightSql.CommandStatementQuery command, FlightProducer.CallContext context, FlightDescriptor descriptor) default SchemaResultFlightSqlProducer.getSchemaSubstraitPlan(FlightSql.CommandStatementSubstraitPlan command, FlightProducer.CallContext context, FlightDescriptor descriptor) Get the result schema for a Substrait plan.