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()


이 페이지가 도움이 되었나요? 평가를 부탁드립니다.

다음에 대한 의견 보내기...

도움이 필요하시나요? 지원 페이지를 방문하세요.