OutputTimeFns (Google Cloud Dataflow SDK 1.9.1 API)

Google Cloud Dataflow SDK for Java, version 1.9.1

com.google.cloud.dataflow.sdk.transforms.windowing

Class OutputTimeFns

  • java.lang.Object
    • com.google.cloud.dataflow.sdk.transforms.windowing.OutputTimeFns
    • Constructor Detail

      • OutputTimeFns

        public OutputTimeFns()
    • Method Detail

      • outputAtEarliestInputTimestamp

        public static OutputTimeFn<BoundedWindow> outputAtEarliestInputTimestamp()
        The policy of outputting at the earliest of the input timestamps for non-late input data that led to a computed value.

        For example, suppose v1 through vn are all on-time elements being aggregated via some function f into f(v1, ..., vn. When emitted, the output timestamp of the result will be the earliest of the event time timestamps

        If data arrives late, it has no effect on the output timestamp.

      • outputAtLatestInputTimestamp

        public static OutputTimeFn<BoundedWindow> outputAtLatestInputTimestamp()
        The policy of holding the watermark to the latest of the input timestamps for non-late input data that led to a computed value.

        For example, suppose v1 through vn are all on-time elements being aggregated via some function f into f(v1, ..., vn. When emitted, the output timestamp of the result will be the latest of the event time timestamps

        If data arrives late, it has no effect on the output timestamp.


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

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

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