public class FlightInfo extends Object
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 |
---|---|
static FlightInfo |
deserialize(ByteBuffer serialized)
Parse the serialized form of this protocol message.
|
boolean |
equals(Object o) |
long |
getBytes() |
FlightDescriptor |
getDescriptor() |
List<FlightEndpoint> |
getEndpoints() |
boolean |
getOrdered() |
long |
getRecords() |
Schema |
getSchema() |
int |
hashCode() |
ByteBuffer |
serialize()
Get the serialized form of this protocol message.
|
String |
toString() |
public FlightInfo(Schema schema, FlightDescriptor descriptor, List<FlightEndpoint> endpoints, long bytes, long records)
schema
- The schema of the Flightdescriptor
- An identifier for the Flight.endpoints
- A list of endpoints that have the flight available.bytes
- The number of bytes in the flightrecords
- The number of records in the flight.public FlightInfo(Schema schema, FlightDescriptor descriptor, List<FlightEndpoint> endpoints, long bytes, long records, IpcOption option)
schema
- The schema of the Flightdescriptor
- An identifier for the Flight.endpoints
- A list of endpoints that have the flight available.bytes
- The number of bytes in the flightrecords
- The number of records in the flight.option
- IPC write options.public FlightInfo(Schema schema, FlightDescriptor descriptor, List<FlightEndpoint> endpoints, long bytes, long records, boolean ordered, IpcOption option)
schema
- The schema of the Flightdescriptor
- An identifier for the Flight.endpoints
- A list of endpoints that have the flight available.bytes
- The number of bytes in the flightrecords
- The number of records in the flight.ordered
- Whether the endpoints in this flight are ordered.option
- IPC write options.public Schema getSchema()
public long getBytes()
public long getRecords()
public FlightDescriptor getDescriptor()
public List<FlightEndpoint> getEndpoints()
public boolean getOrdered()
public ByteBuffer serialize()
Intended to help interoperability by allowing non-Flight services to still return Flight types.
public static FlightInfo deserialize(ByteBuffer serialized) throws IOException, URISyntaxException
Intended to help interoperability by allowing Flight clients to obtain stream info from non-Flight services.
serialized
- The serialized form of the FlightInfo, as returned by serialize()
.IOException
- if the serialized form is invalid.URISyntaxException
- if the serialized form contains an unsupported URI format.Copyright © 2023 The Apache Software Foundation. All rights reserved.