Uploaded image for project: 'Beam'
  1. Beam
  2. BEAM-2889 Flink runs portable pipelines
  3. BEAM-3676

FlinkRunner: Portable state service

    XMLWordPrintableJSON

    Details

      Description

      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.

        Attachments

          Issue Links

            Activity

              People

              • Assignee:
                axelmagn Axel Magnuson
                Reporter:
                bsidhom Ben Sidhom
              • Votes:
                0 Vote for this issue
                Watchers:
                7 Start watching this issue

                Dates

                • Created:
                  Updated:
                  Resolved:

                  Time Tracking

                  Estimated:
                  Original Estimate - Not Specified
                  Not Specified
                  Remaining:
                  Remaining Estimate - 0h
                  0h
                  Logged:
                  Time Spent - 3h 50m
                  3h 50m