beam-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From "Ben Sidhom (JIRA)" <>
Subject [jira] [Created] (BEAM-3676) FlinkRunner: Portable state service
Date Thu, 08 Feb 2018 23:48:00 GMT
Ben Sidhom created BEAM-3676:

             Summary: FlinkRunner: Portable state service
                 Key: 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

View raw message