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]