apache_beam.runners.interactive.options.capture_limiters module

Module to condition how Interactive Beam stops capturing data.

For internal use only; no backwards-compatibility guarantees.

class apache_beam.runners.interactive.options.capture_limiters.Limiter

Bases: object

Limits an aspect of the caching layer.

is_triggered()

Returns True if the limiter has triggered, and caching should stop.

class apache_beam.runners.interactive.options.capture_limiters.SizeLimiter(size_limit)

Bases: apache_beam.runners.interactive.options.capture_limiters.Limiter

Limits the cache size to a specified byte limit.

is_triggered()

class apache_beam.runners.interactive.options.capture_limiters.DurationLimiter(duration_limit)

Bases: apache_beam.runners.interactive.options.capture_limiters.Limiter

Limits the duration of the capture.

is_triggered()