| Package | Description |
|---|---|
| org.apache.arrow.flight | |
| org.apache.arrow.flight.integration.tests |
| Modifier and Type | Method and Description |
|---|---|
static Location |
Location.forGrpcDomainSocket(String path)
Construct a URI for a Flight+gRPC server over a Unix domain socket.
|
static Location |
Location.forGrpcInsecure(String host,
int port)
Construct a URI for a Flight+gRPC server without transport security.
|
static Location |
Location.forGrpcTls(String host,
int port)
Construct a URI for a Flight+gRPC server with transport security.
|
Location |
FlightServer.getLocation()
Get the location for this server.
|
static Location |
Location.reuseConnection()
Construct a special URI to indicate to clients that they may fetch data by reusing
an existing connection to a Flight RPC server.
|
| Modifier and Type | Method and Description |
|---|---|
List<Location> |
FlightEndpoint.getLocations() |
| Modifier and Type | Method and Description |
|---|---|
static FlightClient.Builder |
FlightClient.builder(BufferAllocator allocator,
Location location)
Create a builder for a Flight client.
|
static FlightServer.Builder |
FlightServer.builder(BufferAllocator allocator,
Location location,
FlightProducer producer)
Create a builder for a Flight server.
|
static FlightEndpoint.Builder |
FlightEndpoint.builder(Ticket ticket,
Location... locations)
Create a builder for FlightEndpoint.
|
FlightServer.Builder |
FlightServer.Builder.location(Location location) |
FlightClient.Builder |
FlightClient.Builder.location(Location location) |
| Constructor and Description |
|---|
FlightEndpoint(Ticket ticket,
Instant expirationTime,
Location... locations)
Constructs a new endpoint with an expiration time.
|
FlightEndpoint(Ticket ticket,
Location... locations)
Constructs a new endpoint with no expiration time.
|
| Modifier and Type | Method and Description |
|---|---|
void |
LocationReuseConnectionScenario.client(BufferAllocator allocator,
Location location,
FlightClient client) |
void |
FlightSqlExtensionScenario.client(BufferAllocator allocator,
Location location,
FlightClient client) |
void |
OrderedScenario.client(BufferAllocator allocator,
Location location,
FlightClient client) |
void |
FlightSqlScenario.client(BufferAllocator allocator,
Location location,
FlightClient client) |
FlightProducer |
LocationReuseConnectionScenario.producer(BufferAllocator allocator,
Location location) |
FlightProducer |
OrderedScenario.producer(BufferAllocator allocator,
Location location) |
FlightProducer |
FlightSqlScenario.producer(BufferAllocator allocator,
Location location) |
void |
IntegrationProducer.setLocation(Location location)
Update the location after server start.
|
| Constructor and Description |
|---|
IntegrationProducer(BufferAllocator allocator,
Location location)
Constructs a new instance.
|
Copyright © 2024 The Apache Software Foundation. All rights reserved.