Window.Unbound (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 Window.Unbound

  • java.lang.Object
    • com.google.cloud.dataflow.sdk.transforms.windowing.Window.Unbound
    • Method Detail

      • named

        public Window.Unbound named(String name)
        Returns a new Window transform that's like this transform but with the specified name. Does not modify this transform. The resulting transform is still incomplete.

        See the discussion of Naming in ParDo for more explanation.

      • into

        public <T> Window.Bound<T> into(WindowFn<? super T,?> fn)
        Returns a new Window PTransform that's like this transform but that will use the given WindowFn, and that has its input and output types bound. Does not modify this transform. The resulting PTransform is sufficiently specified to be applied, but more properties can still be specified.
      • discardingFiredPanes

        @Experimental(value=TRIGGER)
        public <T> Window.Bound<T> discardingFiredPanes()
        Returns a new Window PTransform that uses the registered WindowFn and Triggering behavior, and that discards elements in a pane after they are triggered.

        Does not modify this transform. The resulting PTransform is sufficiently specified to be applied, but more properties can still be specified.

      • accumulatingFiredPanes

        @Experimental(value=TRIGGER)
        public <T> Window.Bound<T> accumulatingFiredPanes()
        Returns a new Window PTransform that uses the registered WindowFn and Triggering behavior, and that accumulates elements in a pane after they are triggered.

        Does not modify this transform. The resulting PTransform is sufficiently specified to be applied, but more properties can still be specified.

      • withAllowedLateness

        @Experimental(value=TRIGGER)
        public <T> Window.Bound<T> withAllowedLateness(Duration allowedLateness)
        Override the amount of lateness allowed for data elements in the pipeline. Like the other properties on this Window operation, this will be applied at the next GroupByKey. Any elements that are later than this as decided by the system-maintained watermark will be dropped.

        This value also determines how long state will be kept around for old windows. Once no elements will be added to a window (because this duration has passed) any state associated with the window will be cleaned up.

        Depending on the trigger this may not produce a pane with PaneInfo.isLast. See Window.ClosingBehavior.FIRE_IF_NON_EMPTY for more details.

      • withAllowedLateness

        @Experimental(value=TRIGGER)
        public <T> Window.Bound<T> withAllowedLateness(Duration allowedLateness,
                                                                                    Window.ClosingBehavior behavior)
        Override the amount of lateness allowed for data elements in the pipeline. Like the other properties on this Window operation, this will be applied at the next GroupByKey. Any elements that are later than this as decided by the system-maintained watermark will be dropped.

        This value also determines how long state will be kept around for old windows. Once no elements will be added to a window (because this duration has passed) any state associated with the window will be cleaned up.


Monitor your resources on the go

Get the Google Cloud Console app to help you manage your projects.

Send feedback about...

Cloud Dataflow