Package org.apache.arrow.flight.grpc

Class ServerInterceptorAdapter

java.lang.Object

org.apache.arrow.flight.grpc.ServerInterceptorAdapter

All Implemented Interfaces:

io.grpc.ServerInterceptor

public class ServerInterceptorAdapter
extends Object
implements io.grpc.ServerInterceptor

An adapter between Flight middleware and a gRPC interceptor.

This is implemented as a single gRPC interceptor that runs all Flight server middleware sequentially. Flight middleware instances are stored in the gRPC Context so their state is accessible later.

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static class	ServerInterceptorAdapter.KeyFactory<T extends FlightServerMiddleware>	A combination of a middleware Key and factory.

Field Summary

Fields

Modifier and Type	Field	Description
static final io.grpc.Context.Key<Map<FlightServerMiddleware.Key<?>,FlightServerMiddleware>>	SERVER_MIDDLEWARE_KEY	The Context.Key that stores the Flight middleware active for a particular call.

Constructor Summary

Constructors

Constructor	Description
ServerInterceptorAdapter(List<ServerInterceptorAdapter.KeyFactory<?>> factories)

Method Summary

Modifier and Type	Method	Description
<ReqT, RespT> io.grpc.ServerCall.Listener<ReqT>	interceptCall(io.grpc.ServerCall<ReqT,RespT> call, io.grpc.Metadata headers, io.grpc.ServerCallHandler<ReqT,RespT> next)

Methods inherited from class java.lang.Object

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

Field Details

SERVER_MIDDLEWARE_KEY

public static final io.grpc.Context.Key<Map<FlightServerMiddleware.Key<?>,FlightServerMiddleware>> SERVER_MIDDLEWARE_KEY

The Context.Key that stores the Flight middleware active for a particular call.

Applications should not use this directly. Instead, see FlightProducer.CallContext.getMiddleware(Key).

Constructor Details

ServerInterceptorAdapter

public ServerInterceptorAdapter(List<ServerInterceptorAdapter.KeyFactory<?>> factories)

Method Details

interceptCall

public <ReqT,
RespT>
io.grpc.ServerCall.Listener<ReqT> interceptCall(io.grpc.ServerCall<ReqT,RespT> call,
 io.grpc.Metadata headers,
 io.grpc.ServerCallHandler<ReqT,RespT> next)

Specified by:

interceptCall in interface io.grpc.ServerInterceptor