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

Interface BeamStateHandler<S>

All Known Implementing Classes:

AbstractBeamStateHandler, BeamBagStateHandler, BeamMapStateHandler

public interface BeamStateHandler<S>

Interface for doing actual operations on Flink state based on BeamFnApi.StateRequest.

Method Summary

Modifier and Type	Method and Description
org.apache.beam.model.fnexecution.v1.BeamFnApi.StateResponse.Builder	handle(org.apache.beam.model.fnexecution.v1.BeamFnApi.StateRequest request, S state) Dispatches BeamFnApi.StateRequest to different handle functions base on request case.
org.apache.beam.model.fnexecution.v1.BeamFnApi.StateResponse.Builder	handleAppend(org.apache.beam.model.fnexecution.v1.BeamFnApi.StateRequest request, S state) Handles APPEND requests.
org.apache.beam.model.fnexecution.v1.BeamFnApi.StateResponse.Builder	handleClear(org.apache.beam.model.fnexecution.v1.BeamFnApi.StateRequest request, S state) Handles CLEAR requests.
org.apache.beam.model.fnexecution.v1.BeamFnApi.StateResponse.Builder	handleGet(org.apache.beam.model.fnexecution.v1.BeamFnApi.StateRequest request, S state) Handles GET requests.

Method Detail

handle

org.apache.beam.model.fnexecution.v1.BeamFnApi.StateResponse.Builder handle(org.apache.beam.model.fnexecution.v1.BeamFnApi.StateRequest request,
                                                                            S state)
                                                                     throws Exception

Dispatches BeamFnApi.StateRequest to different handle functions base on request case.

Throws:

Exception

handleGet

org.apache.beam.model.fnexecution.v1.BeamFnApi.StateResponse.Builder handleGet(org.apache.beam.model.fnexecution.v1.BeamFnApi.StateRequest request,
                                                                               S state)
                                                                        throws Exception

Handles GET requests.

Throws:

Exception

handleAppend

org.apache.beam.model.fnexecution.v1.BeamFnApi.StateResponse.Builder handleAppend(org.apache.beam.model.fnexecution.v1.BeamFnApi.StateRequest request,
                                                                                  S state)
                                                                           throws Exception

Handles APPEND requests.

Throws:

Exception

handleClear

org.apache.beam.model.fnexecution.v1.BeamFnApi.StateResponse.Builder handleClear(org.apache.beam.model.fnexecution.v1.BeamFnApi.StateRequest request,
                                                                                 S state)
                                                                          throws Exception

Handles CLEAR requests.

Throws:

Exception