Module org.apache.arrow.flight.core
Package org.apache.arrow.flight.grpc
Class ServerInterceptorAdapter
java.lang.Object
org.apache.arrow.flight.grpc.ServerInterceptorAdapter
- All Implemented Interfaces:
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 ClassesModifier and TypeClassDescriptionstatic class
A combination of a middleware Key and factory. -
Field Summary
FieldsModifier and TypeFieldDescriptionstatic final io.grpc.Context.Key<Map<FlightServerMiddleware.Key<?>,
FlightServerMiddleware>> TheContext.Key
that stores the Flight middleware active for a particular call. -
Constructor Summary
ConstructorsConstructorDescriptionServerInterceptorAdapter
(List<ServerInterceptorAdapter.KeyFactory<?>> factories) -
Method Summary
Modifier and TypeMethodDescription<ReqT,
RespT>
io.grpc.ServerCall.Listener<ReqT>interceptCall
(io.grpc.ServerCall<ReqT, RespT> call, io.grpc.Metadata headers, io.grpc.ServerCallHandler<ReqT, RespT> next)
-
Field Details
-
SERVER_MIDDLEWARE_KEY
public static final io.grpc.Context.Key<Map<FlightServerMiddleware.Key<?>,FlightServerMiddleware>> SERVER_MIDDLEWARE_KEYTheContext.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
-
-
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 interfaceio.grpc.ServerInterceptor
-