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:

io.grpc.BindableService, java.lang.AutoCloseable, FnService, StateDelegator

public class GrpcStateService
extends org.apache.beam.model.fnexecution.v1.BeamFnStateGrpc.BeamFnStateImplBase
implements StateDelegator, FnService

An implementation of the Beam Fn State service.

Method Summary

Modifier and Type	Method and Description
void	close() .
static GrpcStateService	create() Create a new GrpcStateService.
StateDelegator.Registration	registerForProcessBundleInstructionId(java.lang.String processBundleInstructionId, StateRequestHandler handler) Registers the supplied handler for the given process bundle instruction id for all BeamFnApi.StateRequests with a matching id.
io.grpc.stub.StreamObserver<org.apache.beam.model.fnexecution.v1.BeamFnApi.StateRequest>	state(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 io.grpc.BindableService

bindService

Method Detail

create

public static GrpcStateService create()

Create a new GrpcStateService.

close

public void close()
           throws java.lang.Exception

Description copied from interface: FnService

.

There should be no more calls to any service method by the time a call to FnService.close() begins. Specifically, this means that a Server that this service is bound to should have completed a call to the Server.shutdown() method, and all future incoming calls will be rejected.

Specified by:

close in interface java.lang.AutoCloseable

Specified by:

close in interface FnService

Throws:

java.lang.Exception

state

public io.grpc.stub.StreamObserver<org.apache.beam.model.fnexecution.v1.BeamFnApi.StateRequest> state(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 StateDelegator.Registration registerForProcessBundleInstructionId(java.lang.String processBundleInstructionId,
                                                                         StateRequestHandler handler)

Description copied from interface: StateDelegator

Registers the supplied handler for the given process bundle instruction id for all BeamFnApi.StateRequests with a matching id. A handle is returned which allows one to deregister from this StateDelegator.

Specified by:

registerForProcessBundleInstructionId in interface StateDelegator