Package org.apache.beam.sdk.transforms.windowing

Class TimestampTransform.AlignTo

java.lang.Object

org.apache.beam.sdk.transforms.windowing.TimestampTransform

org.apache.beam.sdk.transforms.windowing.TimestampTransform.AlignTo

All Implemented Interfaces:

Serializable

Enclosing class:

TimestampTransform

@Internal
public abstract static class TimestampTransform.AlignTo
extends TimestampTransform

For internal use only; no backwards-compatibility guarantees.

Represents the transform that aligns a timestamp to the next boundary of getPeriod() start at getOffset().

See Also:

• Serialized Form

Nested Class Summary

Nested classes/interfaces inherited from class org.apache.beam.sdk.transforms.windowing.TimestampTransform

TimestampTransform.AlignTo, TimestampTransform.Delay

Constructor Summary

Constructors

Constructor	Description
AlignTo()

Method Summary

Modifier and Type	Method	Description
abstract Instant	getOffset()
abstract Duration	getPeriod()

Methods inherited from class org.apache.beam.sdk.transforms.windowing.TimestampTransform

alignTo, alignTo, delay

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Details

AlignTo

public AlignTo()

Method Details

getPeriod

public abstract Duration getPeriod()

getOffset

public abstract Instant getOffset()