apache_beam.runners.interactive.options.capture_control module

Module to control how Interactive Beam captures data from sources for deterministic replayable PCollection evaluation and pipeline runs.

For internal use only; no backwards-compatibility guarantees.

class apache_beam.runners.interactive.options.capture_control.CaptureControl[source]

Bases: object

Options and their utilities that controls how Interactive Beam captures deterministic replayable data from sources.


Determines if the capture size limit has been reached.


Evicts all deterministic replayable data that have been captured by Interactive Beam. In future PCollection evaluation/visualization and pipeline runs, Interactive Beam will capture fresh data.