apache_beam.transforms.timeutil module¶

Timestamp utilities.

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

Bases: future.types.newobject.newobject

Time domain for streaming timers.

WATERMARK = 'WATERMARK'¶

REAL_TIME = 'REAL_TIME'¶

DEPENDENT_REAL_TIME = 'DEPENDENT_REAL_TIME'¶

static from_string(domain)[source]¶