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:

java.io.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 org.joda.time.Instant	getOffset()
abstract org.joda.time.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 Detail

AlignTo

public AlignTo()

Method Detail

getPeriod

public abstract org.joda.time.Duration getPeriod()

getOffset

public abstract org.joda.time.Instant getOffset()