org.apache.arrow.flight

Class FlightServer.Builder

java.lang.Object

org.apache.arrow.flight.FlightServer.Builder

Enclosing class:

FlightServer

public static final class FlightServer.Builder
extends Object

A builder for Flight servers.

Method Summary

Modifier and Type	Method and Description
FlightServer.Builder	allocator(BufferAllocator allocator)
FlightServer.Builder	authHandler(ServerAuthHandler authHandler) Set the authentication handler.
FlightServer	build() Create the server for this builder.
FlightServer.Builder	executor(ExecutorService executor) Set the executor used by the server.
FlightServer.Builder	headerAuthenticator(CallHeaderAuthenticator headerAuthenticator) Set the header-based authentication mechanism.
FlightServer.Builder	location(Location location)
FlightServer.Builder	maxInboundMessageSize(int maxMessageSize) Set the maximum size of a message.
<T extends FlightServerMiddleware> FlightServer.Builder	middleware(FlightServerMiddleware.Key<T> key, FlightServerMiddleware.Factory<T> factory) Add a Flight middleware component to inspect and modify requests to this service.
FlightServer.Builder	producer(FlightProducer producer)
FlightServer.Builder	transportHint(String key, Object option) Provide a transport-specific option.
FlightServer.Builder	useTls(File certChain, File key) Enable TLS on the server.
FlightServer.Builder	useTls(InputStream certChain, InputStream key) Enable TLS on the server.

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Method Detail

build

public FlightServer build()

Create the server for this builder.

maxInboundMessageSize

public FlightServer.Builder maxInboundMessageSize(int maxMessageSize)

Set the maximum size of a message. Defaults to "unlimited", depending on the underlying transport.

useTls

public FlightServer.Builder useTls(File certChain,
                                   File key)
                            throws IOException

Enable TLS on the server.

Parameters:

certChain - The certificate chain to use.

key - The private key to use.

Throws:

IOException

useTls

public FlightServer.Builder useTls(InputStream certChain,
                                   InputStream key)

Enable TLS on the server.

Parameters:

certChain - The certificate chain to use.

key - The private key to use.

executor

public FlightServer.Builder executor(ExecutorService executor)

Set the executor used by the server.

Flight will NOT take ownership of the executor. The application must clean it up if one is provided. (If not provided, Flight will use a default executor which it will clean up.)

authHandler

public FlightServer.Builder authHandler(ServerAuthHandler authHandler)

Set the authentication handler.

headerAuthenticator

public FlightServer.Builder headerAuthenticator(CallHeaderAuthenticator headerAuthenticator)

Set the header-based authentication mechanism.

transportHint

public FlightServer.Builder transportHint(String key,
                                          Object option)

Provide a transport-specific option. Not guaranteed to have any effect.

middleware

public <T extends FlightServerMiddleware> FlightServer.Builder middleware(FlightServerMiddleware.Key<T> key,
                                                                          FlightServerMiddleware.Factory<T> factory)

Add a Flight middleware component to inspect and modify requests to this service.

Type Parameters:

T - The middleware type.

Parameters:

key - An identifier for this middleware component. Service implementations can retrieve the middleware instance for the current call using FlightProducer.CallContext.

factory - A factory for the middleware.

Throws:

IllegalArgumentException - if the key already exists

allocator

public FlightServer.Builder allocator(BufferAllocator allocator)

location

public FlightServer.Builder location(Location location)

producer

public FlightServer.Builder producer(FlightProducer producer)