apache_beam.runners.interactive.recording_manager module¶
-
class
apache_beam.runners.interactive.recording_manager.
ElementStream
(pcoll, var, cache_key, max_n, max_duration_secs)[source]¶ Bases:
object
A stream of elements from a given PCollection.
-
var
¶ Returns the variable named that defined this PCollection.
-
pcoll
¶ Returns the PCollection that supplies this stream with data.
-
cache_key
¶ Returns the cache key for this stream.
-
-
class
apache_beam.runners.interactive.recording_manager.
Recording
(user_pipeline, pcolls, result, pipeline_instrument, max_n, max_duration_secs)[source]¶ Bases:
object
A group of PCollections from a given pipeline run.