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]