Package org.apache.beam.runners.fnexecution.state

Class GrpcStateService

java.lang.Object

org.apache.beam.model.fnexecution.v1.BeamFnStateGrpc.BeamFnStateImplBase

org.apache.beam.runners.fnexecution.state.GrpcStateService

All Implemented Interfaces:

AutoCloseable, org.apache.beam.runners.fnexecution.state.StateDelegator, org.apache.beam.sdk.fn.server.FnService, org.apache.beam.vendor.grpc.v1p48p1.io.grpc.BindableService

public class GrpcStateService
extends org.apache.beam.model.fnexecution.v1.BeamFnStateGrpc.BeamFnStateImplBase
implements org.apache.beam.runners.fnexecution.state.StateDelegator, org.apache.beam.sdk.fn.server.FnService

An implementation of the Beam Fn State service.

Method Summary

Modifier and Type	Method	Description
void	close()
static GrpcStateService	create()	Create a new GrpcStateService.
org.apache.beam.runners.fnexecution.state.StateDelegator.Registration	registerForProcessBundleInstructionId(String processBundleInstructionId, org.apache.beam.runners.fnexecution.state.StateRequestHandler handler)
org.apache.beam.vendor.grpc.v1p48p1.io.grpc.stub.StreamObserver<org.apache.beam.model.fnexecution.v1.BeamFnApi.StateRequest>	state(org.apache.beam.vendor.grpc.v1p48p1.io.grpc.stub.StreamObserver<org.apache.beam.model.fnexecution.v1.BeamFnApi.StateResponse> responseObserver)

Methods inherited from class org.apache.beam.model.fnexecution.v1.BeamFnStateGrpc.BeamFnStateImplBase

bindService

Methods inherited from class java.lang.Object

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

Methods inherited from interface org.apache.beam.vendor.grpc.v1p48p1.io.grpc.BindableService

bindService

Method Detail

create

public static GrpcStateService create()

Create a new GrpcStateService.

close

public void close()
           throws Exception

Specified by:

close in interface AutoCloseable

Specified by:

close in interface org.apache.beam.sdk.fn.server.FnService

Throws:

Exception

state

public org.apache.beam.vendor.grpc.v1p48p1.io.grpc.stub.StreamObserver<org.apache.beam.model.fnexecution.v1.BeamFnApi.StateRequest> state(org.apache.beam.vendor.grpc.v1p48p1.io.grpc.stub.StreamObserver<org.apache.beam.model.fnexecution.v1.BeamFnApi.StateResponse> responseObserver)

Overrides:

state in class org.apache.beam.model.fnexecution.v1.BeamFnStateGrpc.BeamFnStateImplBase

registerForProcessBundleInstructionId

public org.apache.beam.runners.fnexecution.state.StateDelegator.Registration registerForProcessBundleInstructionId(String processBundleInstructionId,
                                                                                                                   org.apache.beam.runners.fnexecution.state.StateRequestHandler handler)

Specified by:

registerForProcessBundleInstructionId in interface org.apache.beam.runners.fnexecution.state.StateDelegator