Package | Description |
---|---|
org.apache.arrow.driver.jdbc | |
org.apache.arrow.driver.jdbc.client | |
org.apache.arrow.flight | |
org.apache.arrow.flight.integration.tests | |
org.apache.arrow.flight.sql |
Modifier and Type | Method and Description |
---|---|
FlightInfo |
ArrowFlightInfoStatement.executeFlightInfoQuery()
Executes the query this
Statement is holding. |
FlightInfo |
ArrowFlightPreparedStatement.executeFlightInfoQuery() |
FlightInfo |
ArrowFlightStatement.executeFlightInfoQuery() |
Modifier and Type | Method and Description |
---|---|
FlightInfo |
ArrowFlightSqlClientHandler.PreparedStatement.executeQuery()
Executes this
ArrowFlightSqlClientHandler.PreparedStatement . |
FlightInfo |
ArrowFlightSqlClientHandler.getCatalogs()
Makes an RPC "getCatalogs" request.
|
FlightInfo |
ArrowFlightSqlClientHandler.getCrossReference(String pkCatalog,
String pkSchema,
String pkTable,
String fkCatalog,
String fkSchema,
String fkTable)
Makes an RPC "getCrossReference" request based on the provided info.
|
FlightInfo |
ArrowFlightSqlClientHandler.getExportedKeys(String catalog,
String schema,
String table)
Makes an RPC "getExportedKeys" request based on the provided info.
|
FlightInfo |
ArrowFlightSqlClientHandler.getImportedKeys(String catalog,
String schema,
String table)
Makes an RPC "getImportedKeys" request based on the provided info.
|
FlightInfo |
ArrowFlightSqlClientHandler.getInfo(String query)
Makes an RPC "getInfo" request based on the provided
query
object. |
FlightInfo |
ArrowFlightSqlClientHandler.getPrimaryKeys(String catalog,
String schema,
String table)
Makes an RPC "getPrimaryKeys" request based on the provided info.
|
FlightInfo |
ArrowFlightSqlClientHandler.getSchemas(String catalog,
String schemaPattern)
Makes an RPC "getSchemas" request based on the provided info.
|
FlightInfo |
ArrowFlightSqlClientHandler.getSqlInfo(FlightSql.SqlInfo... info)
Gets SQL info.
|
FlightInfo |
ArrowFlightSqlClientHandler.getTables(String catalog,
String schemaPattern,
String tableNamePattern,
List<String> types,
boolean includeSchema)
Makes an RPC "getTables" request based on the provided info.
|
FlightInfo |
ArrowFlightSqlClientHandler.getTableTypes()
Makes an RPC "getTableTypes" request.
|
Modifier and Type | Method and Description |
---|---|
List<CloseableEndpointStreamPair> |
ArrowFlightSqlClientHandler.getStreams(FlightInfo flightInfo)
Makes an RPC "getStream" request based on the provided
FlightInfo
object. |
Modifier and Type | Method and Description |
---|---|
FlightInfo |
FlightInfo.Builder.build()
Build FlightInfo object.
|
static FlightInfo |
FlightInfo.deserialize(ByteBuffer serialized)
Parse the serialized form of this protocol message.
|
FlightInfo |
PollInfo.getFlightInfo()
The FlightInfo describing the result set of the execution of a query.
|
FlightInfo |
FlightProducer.getFlightInfo(FlightProducer.CallContext context,
FlightDescriptor descriptor)
Get information about a particular data stream.
|
FlightInfo |
NoOpFlightProducer.getFlightInfo(FlightProducer.CallContext context,
FlightDescriptor descriptor) |
FlightInfo |
CancelFlightInfoRequest.getInfo() |
FlightInfo |
FlightClient.getInfo(FlightDescriptor descriptor,
CallOption... options)
Get info on a stream.
|
Modifier and Type | Method and Description |
---|---|
Iterable<FlightInfo> |
FlightClient.listFlights(Criteria criteria,
CallOption... options)
Get a list of available flights.
|
Modifier and Type | Method and Description |
---|---|
void |
FlightProducer.listFlights(FlightProducer.CallContext context,
Criteria criteria,
FlightProducer.StreamListener<FlightInfo> listener)
List available data streams on this service.
|
void |
NoOpFlightProducer.listFlights(FlightProducer.CallContext context,
Criteria criteria,
FlightProducer.StreamListener<FlightInfo> listener) |
Constructor and Description |
---|
CancelFlightInfoRequest(FlightInfo info) |
PollInfo(FlightInfo flightInfo,
FlightDescriptor flightDescriptor,
Double progress,
Instant expirationTime)
Create a new PollInfo.
|
Modifier and Type | Method and Description |
---|---|
void |
FlightSqlScenarioProducer.cancelQuery(FlightInfo info,
FlightProducer.CallContext context,
FlightProducer.StreamListener<CancelResult> listener) |
protected void |
FlightSqlScenario.validate(Schema expectedSchema,
FlightInfo flightInfo,
FlightSqlClient sqlClient) |
Modifier and Type | Method and Description |
---|---|
void |
FlightSqlScenarioProducer.listFlights(FlightProducer.CallContext context,
Criteria criteria,
FlightProducer.StreamListener<FlightInfo> listener) |
Modifier and Type | Method and Description |
---|---|
FlightInfo |
FlightSqlClient.PreparedStatement.execute(CallOption... options)
Executes the prepared statement query on the server.
|
FlightInfo |
FlightSqlClient.execute(String query,
CallOption... options)
Execute a query on the server.
|
FlightInfo |
FlightSqlClient.execute(String query,
FlightSqlClient.Transaction transaction,
CallOption... options)
Execute a query on the server.
|
FlightInfo |
FlightSqlClient.executeSubstrait(FlightSqlClient.SubstraitPlan plan,
CallOption... options)
Execute a Substrait plan on the server.
|
FlightInfo |
FlightSqlClient.executeSubstrait(FlightSqlClient.SubstraitPlan plan,
FlightSqlClient.Transaction transaction,
CallOption... options)
Execute a Substrait plan on the server.
|
protected <T extends com.google.protobuf.Message> |
BasicFlightSqlProducer.generateFlightInfo(T request,
FlightDescriptor descriptor,
Schema schema) |
FlightInfo |
FlightSqlClient.getCatalogs(CallOption... options)
Request a list of catalogs.
|
FlightInfo |
FlightSqlClient.getCrossReference(TableRef pkTableRef,
TableRef fkTableRef,
CallOption... options)
Retrieves a description of the foreign key columns that reference the given table's
primary key columns (the foreign keys exported by a table).
|
FlightInfo |
FlightSqlClient.getExportedKeys(TableRef tableRef,
CallOption... options)
Retrieves a description about the foreign key columns that reference the primary key columns of the given table.
|
default FlightInfo |
FlightSqlProducer.getFlightInfo(FlightProducer.CallContext context,
FlightDescriptor descriptor)
Depending on the provided command, method either:
1.
|
FlightInfo |
BasicFlightSqlProducer.getFlightInfoCatalogs(FlightSql.CommandGetCatalogs request,
FlightProducer.CallContext context,
FlightDescriptor descriptor) |
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 |
NoOpFlightSqlProducer.getFlightInfoCatalogs(FlightSql.CommandGetCatalogs request,
FlightProducer.CallContext context,
FlightDescriptor descriptor) |
FlightInfo |
BasicFlightSqlProducer.getFlightInfoCrossReference(FlightSql.CommandGetCrossReference request,
FlightProducer.CallContext context,
FlightDescriptor descriptor) |
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 |
NoOpFlightSqlProducer.getFlightInfoCrossReference(FlightSql.CommandGetCrossReference request,
FlightProducer.CallContext context,
FlightDescriptor descriptor) |
FlightInfo |
BasicFlightSqlProducer.getFlightInfoExportedKeys(FlightSql.CommandGetExportedKeys request,
FlightProducer.CallContext context,
FlightDescriptor descriptor) |
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 |
NoOpFlightSqlProducer.getFlightInfoExportedKeys(FlightSql.CommandGetExportedKeys request,
FlightProducer.CallContext context,
FlightDescriptor descriptor) |
FlightInfo |
BasicFlightSqlProducer.getFlightInfoImportedKeys(FlightSql.CommandGetImportedKeys request,
FlightProducer.CallContext context,
FlightDescriptor descriptor) |
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 |
NoOpFlightSqlProducer.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 |
BasicFlightSqlProducer.getFlightInfoPrimaryKeys(FlightSql.CommandGetPrimaryKeys request,
FlightProducer.CallContext context,
FlightDescriptor descriptor) |
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 |
NoOpFlightSqlProducer.getFlightInfoPrimaryKeys(FlightSql.CommandGetPrimaryKeys request,
FlightProducer.CallContext context,
FlightDescriptor descriptor) |
FlightInfo |
BasicFlightSqlProducer.getFlightInfoSchemas(FlightSql.CommandGetDbSchemas request,
FlightProducer.CallContext context,
FlightDescriptor descriptor) |
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 |
NoOpFlightSqlProducer.getFlightInfoSchemas(FlightSql.CommandGetDbSchemas request,
FlightProducer.CallContext context,
FlightDescriptor descriptor) |
FlightInfo |
BasicFlightSqlProducer.getFlightInfoSqlInfo(FlightSql.CommandGetSqlInfo request,
FlightProducer.CallContext context,
FlightDescriptor descriptor) |
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 |
NoOpFlightSqlProducer.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 |
BasicFlightSqlProducer.getFlightInfoTables(FlightSql.CommandGetTables request,
FlightProducer.CallContext context,
FlightDescriptor descriptor) |
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 |
NoOpFlightSqlProducer.getFlightInfoTables(FlightSql.CommandGetTables request,
FlightProducer.CallContext context,
FlightDescriptor descriptor) |
FlightInfo |
BasicFlightSqlProducer.getFlightInfoTableTypes(FlightSql.CommandGetTableTypes request,
FlightProducer.CallContext context,
FlightDescriptor descriptor) |
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 |
NoOpFlightSqlProducer.getFlightInfoTableTypes(FlightSql.CommandGetTableTypes request,
FlightProducer.CallContext context,
FlightDescriptor descriptor) |
FlightInfo |
BasicFlightSqlProducer.getFlightInfoTypeInfo(FlightSql.CommandGetXdbcTypeInfo 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 |
FlightSqlClient.getImportedKeys(TableRef tableRef,
CallOption... options)
Retrieves the foreign key columns for the given table.
|
FlightInfo |
FlightSqlClient.getPrimaryKeys(TableRef tableRef,
CallOption... options)
Request the primary keys for a table.
|
FlightInfo |
FlightSqlClient.getSchemas(String catalog,
String dbSchemaFilterPattern,
CallOption... options)
Request a list of schemas.
|
FlightInfo |
FlightSqlClient.getSqlInfo(FlightSql.SqlInfo... info)
Request a set of Flight SQL metadata.
|
FlightInfo |
FlightSqlClient.getSqlInfo(FlightSql.SqlInfo[] info,
CallOption... options)
Request a set of Flight SQL metadata.
|
FlightInfo |
FlightSqlClient.getSqlInfo(int[] info,
CallOption... options)
Request a set of Flight SQL metadata.
|
FlightInfo |
FlightSqlClient.getSqlInfo(Iterable<Integer> info,
CallOption... options)
Request a set of Flight SQL metadata.
|
FlightInfo |
FlightSqlClient.getTables(String catalog,
String dbSchemaFilterPattern,
String tableFilterPattern,
List<String> tableTypes,
boolean includeSchema,
CallOption... options)
Request a list of tables.
|
FlightInfo |
FlightSqlClient.getTableTypes(CallOption... options)
Request a list of table types.
|
FlightInfo |
FlightSqlClient.getXdbcTypeInfo(CallOption... options)
Request the information about all the data types supported.
|
FlightInfo |
FlightSqlClient.getXdbcTypeInfo(int dataType,
CallOption... options)
Request the information about the data types supported related to
a filter data type.
|
Modifier and Type | Method and Description |
---|---|
CancelResult |
FlightSqlClient.cancelQuery(FlightInfo info,
CallOption... options)
|
default void |
FlightSqlProducer.cancelQuery(FlightInfo info,
FlightProducer.CallContext context,
FlightProducer.StreamListener<CancelResult> listener)
Deprecated.
Prefer
#cancelFlightInfo(FlightInfo, CallContext, StreamListener) . |
Modifier and Type | Method and Description |
---|---|
void |
NoOpFlightSqlProducer.listFlights(FlightProducer.CallContext context,
Criteria criteria,
FlightProducer.StreamListener<FlightInfo> listener) |
Copyright © 2024 The Apache Software Foundation. All rights reserved.