| Package | Description |
|---|---|
| org.apache.arrow.flight | |
| org.apache.arrow.flight.integration.tests | |
| org.apache.arrow.flight.sql |
| Modifier and Type | Method and Description |
|---|---|
static FlightDescriptor |
FlightDescriptor.command(byte[] cmd) |
static FlightDescriptor |
FlightDescriptor.deserialize(ByteBuffer serialized)
Parse the serialized form of this protocol message.
|
FlightDescriptor |
FlightInfo.getDescriptor() |
FlightDescriptor |
FlightStream.getDescriptor()
Get the descriptor for this stream.
|
static FlightDescriptor |
FlightDescriptor.path(Iterable<String> path) |
static FlightDescriptor |
FlightDescriptor.path(String... path) |
| Modifier and Type | Method and Description |
|---|---|
FlightClient.ExchangeReaderWriter |
FlightClient.doExchange(FlightDescriptor descriptor,
CallOption... options)
Initiate a bidirectional data exchange with the server.
|
FlightInfo |
FlightProducer.getFlightInfo(FlightProducer.CallContext context,
FlightDescriptor descriptor)
Get information about a particular data stream.
|
FlightInfo |
NoOpFlightProducer.getFlightInfo(FlightProducer.CallContext context,
FlightDescriptor descriptor) |
FlightInfo |
FlightClient.getInfo(FlightDescriptor descriptor,
CallOption... options)
Get info on a stream.
|
SchemaResult |
FlightClient.getSchema(FlightDescriptor descriptor,
CallOption... options)
Get schema for a stream.
|
default SchemaResult |
FlightProducer.getSchema(FlightProducer.CallContext context,
FlightDescriptor descriptor)
Get schema for a particular data stream.
|
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.
|
| Constructor and Description |
|---|
FlightInfo(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,
IpcOption option)
Constructs a new instance.
|
| Modifier and Type | Method and Description |
|---|---|
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)
Returns the available catalogs by returning a stream of
FlightSql.CommandGetCatalogs objects in Result objects. |
FlightInfo |
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 columns
FlightSql.CommandGetCrossReference objects in Result objects. |
FlightInfo |
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 columns
FlightSql.CommandGetExportedKeys objects in Result objects. |
FlightInfo |
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 columns
FlightSql.CommandGetImportedKeys objects in Result objects. |
FlightInfo |
FlightSqlProducer.getFlightInfoPreparedStatement(FlightSql.CommandPreparedStatementQuery command,
FlightProducer.CallContext context,
FlightDescriptor descriptor)
Gets information about a particular prepared statement data stream.
|
FlightInfo |
FlightSqlProducer.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 |
FlightSqlProducer.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 |
FlightSqlProducer.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 |
FlightSqlProducer.getFlightInfoStatement(FlightSql.CommandStatementQuery command,
FlightProducer.CallContext context,
FlightDescriptor descriptor)
Evaluate a SQL query.
|
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)
Returns the available tables by returning a stream of
FlightSql.CommandGetTables objects in Result objects. |
FlightInfo |
FlightSqlProducer.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 |
FlightSqlProducer.getFlightInfoTypeInfo(FlightSql.CommandGetXdbcTypeInfo request,
FlightProducer.CallContext context,
FlightDescriptor descriptor)
Returns a description of all the data types supported by source.
|
SchemaResult |
FlightSqlClient.getSchema(FlightDescriptor descriptor,
CallOption... options)
Get schema for a stream.
|
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.
|
default SchemaResult |
FlightSqlProducer.getSchemaSubstraitPlan(FlightSql.CommandStatementSubstraitPlan command,
FlightProducer.CallContext context,
FlightDescriptor descriptor)
Get the result schema for a Substrait plan.
|
Copyright © 2023 The Apache Software Foundation. All rights reserved.