apache_beam.runners.interactive.caching.streaming_cache module

class apache_beam.runners.interactive.caching.streaming_cache.StreamingCache(readers)[source]

Bases: object

Abstraction that holds the logic for reading and writing to cache.

class Reader(readers)[source]

Bases: object

Abstraction that reads from PCollection readers.

This class is an Abstraction layer over multiple PCollection readers to be used for supplying a TestStream service with events.

This class is also responsible for holding the state of the clock, injecting clock advancement events, and watermark advancement events.

read()[source]

Reads records from PCollection readers.

reader()[source]