apache_beam.runners.interactive.testing.test_cache_manager module¶

class apache_beam.runners.interactive.testing.test_cache_manager.InMemoryCache[source]¶

Bases: 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)[source]¶

read(*labels, **args)[source]¶

write(value, *labels)[source]¶

save_pcoder(pcoder, *labels)[source]¶

load_pcoder(*labels)[source]¶

cleanup()[source]¶

clear(*label)[source]¶

source(*labels)[source]¶

sink(labels, is_capture=False)[source]¶

size(*labels)[source]¶

class apache_beam.runners.interactive.testing.test_cache_manager.NoopSink(label: str | None = None)[source]¶

Bases: PTransform

expand(pcoll)[source]¶

class apache_beam.runners.interactive.testing.test_cache_manager.FileRecordsBuilder(tag=None)[source]¶

Bases: object

add_element(element, event_time_secs)[source]¶

advance_watermark(watermark_secs)[source]¶

advance_processing_time(delta_secs)[source]¶

build()[source]¶