apache_beam.transforms.timeutil module¶

Timestamp utilities.

class apache_beam.transforms.timeutil.TimeDomain[source]¶

Bases: object

Time domain for streaming timers.

WATERMARK = 'WATERMARK'¶

REAL_TIME = 'REAL_TIME'¶

DEPENDENT_REAL_TIME = 'DEPENDENT_REAL_TIME'¶

static from_string(domain)[source]¶

static to_runner_api(domain)[source]¶

static is_event_time(domain)[source]¶