apache_beam.runners.interactive.testing.test_cache_manager module

class apache_beam.runners.interactive.testing.test_cache_manager.InMemoryCache

Bases: apache_beam.runners.interactive.cache_manager.CacheManager

A cache that stores all PCollections in an in-memory map.

This is only used for checking the pipeline shape. This can’t be used for running the pipeline isn’t shared between the SDK and the Runner.

exists(*labels)

read(*labels)

write(value, *labels)

save_pcoder(pcoder, *labels)

load_pcoder(*labels)

cleanup()

source(*labels)

sink(labels, is_capture=False)

class apache_beam.runners.interactive.testing.test_cache_manager.NoopSink(label=None)

Bases: apache_beam.transforms.ptransform.PTransform

expand(pcoll)

class apache_beam.runners.interactive.testing.test_cache_manager.FileRecordsBuilder(tag=None)

Bases: object

add_element(element, event_time_secs)

advance_watermark(watermark_secs)

advance_processing_time(delta_secs)

build()