Class AbstractBeamStateHandler<S>

    • Constructor Detail

      • AbstractBeamStateHandler

        public AbstractBeamStateHandler()
    • Method Detail

      • handle

        public org.apache.beam.model.fnexecution.v1.BeamFnApi.StateResponse.Builder handle​(org.apache.beam.model.fnexecution.v1.BeamFnApi.StateRequest request,
                                                                                           S state)
                                                                                    throws Exception
        Description copied from interface: BeamStateHandler
        Dispatches BeamFnApi.StateRequest to different handle functions base on request case.
        Specified by:
        handle in interface BeamStateHandler<S>
        Throws:
        Exception