Details
-
Improvement
-
Status: Resolved
-
P2
-
Resolution: Fixed
-
None
-
None
Description
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