public class GrpcStateService extends org.apache.beam.model.fnexecution.v1.BeamFnStateGrpc.BeamFnStateImplBase implements StateDelegator, FnService
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.StateRequest s with a matching id. |
org.apache.beam.vendor.grpc.v1p54p0.io.grpc.stub.StreamObserver<org.apache.beam.model.fnexecution.v1.BeamFnApi.StateRequest> |
state(org.apache.beam.vendor.grpc.v1p54p0.io.grpc.stub.StreamObserver<org.apache.beam.model.fnexecution.v1.BeamFnApi.StateResponse> responseObserver) |
bindService
public static GrpcStateService create()
GrpcStateService
.public void close() throws java.lang.Exception
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.
public org.apache.beam.vendor.grpc.v1p54p0.io.grpc.stub.StreamObserver<org.apache.beam.model.fnexecution.v1.BeamFnApi.StateRequest> state(org.apache.beam.vendor.grpc.v1p54p0.io.grpc.stub.StreamObserver<org.apache.beam.model.fnexecution.v1.BeamFnApi.StateResponse> responseObserver)
state
in interface org.apache.beam.model.fnexecution.v1.BeamFnStateGrpc.AsyncService
public StateDelegator.Registration registerForProcessBundleInstructionId(java.lang.String processBundleInstructionId, StateRequestHandler handler)
StateDelegator
BeamFnApi.StateRequest
s with a matching id. A handle is returned which allows one to deregister from
this StateDelegator
.registerForProcessBundleInstructionId
in interface StateDelegator