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.


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

Send feedback about...

Cloud Dataflow