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 |
FlightStream.getDescriptor()
Get the descriptor for this stream.
|
FlightDescriptor |
FlightInfo.getDescriptor() |
static FlightDescriptor |
FlightDescriptor.path(Iterable<String> path) |
static FlightDescriptor |
FlightDescriptor.path(String... path) |
Modifier and Type | Method and Description |
---|---|
Optional<FlightDescriptor> |
PollInfo.getFlightDescriptor()
The FlightDescriptor that should be used to get further updates on this query.
|
Modifier and Type | Method and Description |
---|---|
static FlightInfo.Builder |
FlightInfo.builder(Schema schema,
FlightDescriptor descriptor,
List<FlightEndpoint> endpoints)
Create a builder for FlightInfo.
|
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.
|
default PollInfo |
FlightProducer.pollFlightInfo(FlightProducer.CallContext context,
FlightDescriptor descriptor)
Begin or get an update on execution of a long-running query.
|
PollInfo |
FlightClient.pollInfo(FlightDescriptor descriptor,
CallOption... options)
Start or get info on execution of a long-running query.
|
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,
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.
|
Copyright © 2024 The Apache Software Foundation. All rights reserved.