Package | Description |
---|---|
org.apache.arrow.flight | |
org.apache.arrow.flight.sql |
Modifier and Type | Method and Description |
---|---|
static FlightEndpoint |
FlightEndpoint.deserialize(ByteBuffer serialized)
Parse the serialized form of this protocol message.
|
FlightEndpoint |
RenewFlightEndpointRequest.getFlightEndpoint() |
FlightEndpoint |
FlightClient.renewFlightEndpoint(RenewFlightEndpointRequest request,
CallOption... options)
Request the server to extend the lifetime of a query result set.
|
Modifier and Type | Method and Description |
---|---|
List<FlightEndpoint> |
FlightInfo.getEndpoints() |
Constructor and Description |
---|
RenewFlightEndpointRequest(FlightEndpoint endpoint) |
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,
IpcOption option)
Constructs a new instance.
|
Modifier and Type | Method and Description |
---|---|
FlightEndpoint |
FlightSqlClient.renewFlightEndpoint(RenewFlightEndpointRequest request,
CallOption... options)
Request the server to extend the lifetime of a query result set.
|
Modifier and Type | Method and Description |
---|---|
protected abstract <T extends com.google.protobuf.Message> |
BasicFlightSqlProducer.determineEndpoints(T request,
FlightDescriptor flightDescriptor,
Schema schema)
Return a list of FlightEndpoints for the given request and FlightDescriptor.
|
Modifier and Type | Method and Description |
---|---|
void |
FlightEndpointListener.onNext(FlightEndpoint val) |
Modifier and Type | Method and Description |
---|---|
default void |
FlightSqlProducer.renewFlightEndpoint(RenewFlightEndpointRequest request,
FlightProducer.CallContext context,
FlightProducer.StreamListener<FlightEndpoint> listener)
Renew the duration of the given endpoint.
|
Copyright © 2023 The Apache Software Foundation. All rights reserved.