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.
-
limiters()[source]
-
set_limiters_for_test(limiters)[source]
-
apache_beam.runners.interactive.options.capture_control.evict_captured_data()[source]
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.