org.apache.beam.runners.fnexecution

Class GrpcContextHeaderAccessorProvider

java.lang.Object

org.apache.beam.runners.fnexecution.GrpcContextHeaderAccessorProvider

public class GrpcContextHeaderAccessorProvider
extends java.lang.Object

A HeaderAccessorProvider which intercept the header in a GRPC request and expose the relevant fields.

Constructor Summary

Constructors

Constructor and Description
GrpcContextHeaderAccessorProvider()

Method Summary

Modifier and Type	Method and Description
static HeaderAccessor	getHeaderAccessor()
static org.apache.beam.vendor.grpc.v1p21p0.io.grpc.ServerInterceptor	interceptor()

Methods inherited from class java.lang.Object

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

Constructor Detail

GrpcContextHeaderAccessorProvider

public GrpcContextHeaderAccessorProvider()

Method Detail

interceptor

public static org.apache.beam.vendor.grpc.v1p21p0.io.grpc.ServerInterceptor interceptor()

getHeaderAccessor

public static HeaderAccessor getHeaderAccessor()