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)