org.apache.flink.streaming.api.runners.python.beam

Class SimpleStateRequestHandler

java.lang.Object

org.apache.flink.streaming.api.runners.python.beam.SimpleStateRequestHandler

All Implemented Interfaces:

org.apache.beam.runners.fnexecution.state.StateRequestHandler

@Internal
public class SimpleStateRequestHandler
extends Object
implements org.apache.beam.runners.fnexecution.state.StateRequestHandler

A state request handler which handles the state request from Python side.

Method Summary

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)

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.runners.fnexecution.state.StateRequestHandler

unsupported

Method Detail

getCacheTokens

public Iterable<org.apache.beam.model.fnexecution.v1.BeamFnApi.ProcessBundleRequest.CacheToken> getCacheTokens()

Specified by:

getCacheTokens in interface org.apache.beam.runners.fnexecution.state.StateRequestHandler

handle

public CompletionStage<org.apache.beam.model.fnexecution.v1.BeamFnApi.StateResponse.Builder> handle(org.apache.beam.model.fnexecution.v1.BeamFnApi.StateRequest request)
                                                                                             throws Exception

Specified by:

handle in interface org.apache.beam.runners.fnexecution.state.StateRequestHandler

Throws:

Exception