Sam Rohde created BEAM-8335: ------------------------------- Summary: Add streaming support to Interactive Beam Key: BEAM-8335 URL: https://issues.apache.org/jira/browse/BEAM-8335 Project: Beam Issue Type: Improvement Components: runner-py-interactive Reporter: Sam Rohde Assignee: Sam Rohde
This issue tracks the work items to introduce streaming support to the Interactive Beam experience. This will allow users to: * Write and run a streaming job in IPython * Automatically cache records from unbounded sources * Add a replay experience that replays all cached records to simulate the original pipeline execution * Add controls to play/pause/stop/step individual elements from the cached records * Add ability to inspect/visualize unbounded PCollections -- This message was sent by Atlassian Jira (v8.3.4#803005)