You are viewing a plain text version of this content. The canonical link for it is here.

Posted to commits@beam.apache.org by "Ben Sidhom (JIRA)" <ji...@apache.org> on 2018/02/08 23:48:00 UTC

[jira] [Created] (BEAM-3676) FlinkRunner: Portable state service

Ben Sidhom created BEAM-3676:
--------------------------------

             Summary: FlinkRunner: Portable state service
                 Key: BEAM-3676
                 URL: https://issues.apache.org/jira/browse/BEAM-3676
             Project: Beam
          Issue Type: Sub-task
          Components: runner-flink
            Reporter: Ben Sidhom
            Assignee: Aljoscha Krettek


The State API is an implementation of BeamFnState that exposes pipeline state to SDK harnesses. Because it is used for side inputs, this service will also need to be tied into side inputs/outputs during the translation phase.



--
This message was sent by Atlassian JIRA
(v7.6.3#76005)