WithTimestamps (Google Cloud Dataflow SDK 1.9.1 API)

Google Cloud Dataflow SDK for Java, version 1.9.1

com.google.cloud.dataflow.sdk.transforms

Class WithTimestamps<T>

    • Method Detail

      • withAllowedTimestampSkew

        public WithTimestamps<T> withAllowedTimestampSkew(Duration allowedTimestampSkew)
        Return a new WithTimestamps like this one with updated allowed timestamp skew, which is the maximum duration that timestamps can be shifted backward. Does not modify this object.

        The default value is Duration.ZERO, allowing timestamps to only be shifted into the future. For infinite skew, use new Duration(Long.MAX_VALUE).

      • getAllowedTimestampSkew

        public Duration getAllowedTimestampSkew()
        Returns the allowed timestamp skew duration, which is the maximum duration that timestamps can be shifted backwards from the timestamp of the input element.
        See Also:
        DoFn.getAllowedTimestampSkew()


Was this page helpful? Let us know how we did:

Send feedback about...

Cloud Dataflow