@Internal public class SimpleStateRequestHandler extends Object implements org.apache.beam.runners.fnexecution.state.StateRequestHandler
Modifier and Type | Method and Description |
---|---|
Iterable<org.apache.beam.model.fnexecution.v1.BeamFnApi.ProcessBundleRequest.CacheToken> |
getCacheTokens() |
CompletionStage<org.apache.beam.model.fnexecution.v1.BeamFnApi.StateResponse.Builder> |
handle(org.apache.beam.model.fnexecution.v1.BeamFnApi.StateRequest request) |
public Iterable<org.apache.beam.model.fnexecution.v1.BeamFnApi.ProcessBundleRequest.CacheToken> getCacheTokens()
getCacheTokens
in interface org.apache.beam.runners.fnexecution.state.StateRequestHandler
public CompletionStage<org.apache.beam.model.fnexecution.v1.BeamFnApi.StateResponse.Builder> handle(org.apache.beam.model.fnexecution.v1.BeamFnApi.StateRequest request) throws Exception
handle
in interface org.apache.beam.runners.fnexecution.state.StateRequestHandler
Exception
Copyright © 2014–2023 The Apache Software Foundation. All rights reserved.