Class TimestampTransform
- java.lang.Object
-
- org.apache.beam.sdk.transforms.windowing.TimestampTransform
-
- All Implemented Interfaces:
java.io.Serializable
- Direct Known Subclasses:
TimestampTransform.AlignTo
,TimestampTransform.Delay
@Internal public abstract class TimestampTransform extends java.lang.Object implements java.io.Serializable
For internal use only; no backwards-compatibility guarantees.An abstract description of a standardized transformation on timestamps.
- See Also:
- Serialized Form
-
-
Nested Class Summary
Nested Classes Modifier and Type Class Description static class
TimestampTransform.AlignTo
For internal use only; no backwards-compatibility guarantees.static class
TimestampTransform.Delay
For internal use only; no backwards-compatibility guarantees.
-
Method Summary
All Methods Static Methods Concrete Methods Modifier and Type Method Description static TimestampTransform
alignTo(org.joda.time.Duration period)
For internal use only; no backwards-compatibility guarantees.static TimestampTransform
alignTo(org.joda.time.Duration period, org.joda.time.Instant offset)
For internal use only; no backwards-compatibility guarantees.static TimestampTransform
delay(org.joda.time.Duration delay)
For internal use only; no backwards-compatibility guarantees.
-
-
-
Method Detail
-
delay
@Internal public static TimestampTransform delay(org.joda.time.Duration delay)
For internal use only; no backwards-compatibility guarantees.Returns a transform that shifts a timestamp later by
delay
.
-
alignTo
@Internal public static TimestampTransform alignTo(org.joda.time.Duration period, org.joda.time.Instant offset)
For internal use only; no backwards-compatibility guarantees.Returns a transform that aligns a timestamp to the next boundary of
period
, starting fromoffset
.
-
alignTo
@Internal public static TimestampTransform alignTo(org.joda.time.Duration period)
For internal use only; no backwards-compatibility guarantees.Returns a transform that aligns a timestamp to the next boundary of
period
, starting from the start of the epoch.
-
-