public class FlightGrpcUtils extends Object
Modifier and Type | Method and Description |
---|---|
static FlightClient |
createFlightClient(BufferAllocator incomingAllocator,
io.grpc.ManagedChannel channel)
Creates a Flight client.
|
static FlightClient |
createFlightClientWithSharedChannel(BufferAllocator incomingAllocator,
io.grpc.ManagedChannel channel)
Creates a Flight client.
|
static io.grpc.BindableService |
createFlightService(BufferAllocator allocator,
FlightProducer producer,
ServerAuthHandler authHandler,
ExecutorService executor)
Creates a Flight service.
|
public static io.grpc.BindableService createFlightService(BufferAllocator allocator, FlightProducer producer, ServerAuthHandler authHandler, ExecutorService executor)
allocator
- Memory allocatorproducer
- Specifies the service apiauthHandler
- Authentication handlerexecutor
- Executor servicepublic static FlightClient createFlightClient(BufferAllocator incomingAllocator, io.grpc.ManagedChannel channel)
incomingAllocator
- Memory allocatorchannel
- provides a connection to a gRPC server.public static FlightClient createFlightClientWithSharedChannel(BufferAllocator incomingAllocator, io.grpc.ManagedChannel channel)
incomingAllocator
- Memory allocatorchannel
- provides a connection to a gRPC server. Will not be closed on closure of the returned FlightClient.Copyright © 2023 The Apache Software Foundation. All rights reserved.