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

Class PartitioningWindowFn<T,W extends BoundedWindow>

java.lang.Object

com.google.cloud.dataflow.sdk.transforms.windowing.WindowFn<T,W>

com.google.cloud.dataflow.sdk.transforms.windowing.NonMergingWindowFn<T,W>

com.google.cloud.dataflow.sdk.transforms.windowing.PartitioningWindowFn<T,W>

Type Parameters:

T - type of elements being windowed

W - window type

All Implemented Interfaces:

java.io.Serializable

Direct Known Subclasses:

CalendarWindows.DaysWindows, CalendarWindows.MonthsWindows, CalendarWindows.YearsWindows, FixedWindows

public abstract class PartitioningWindowFn<T,W extends BoundedWindow>
extends NonMergingWindowFn<T,W>

A WindowFn that places each value into exactly one window based on its timestamp and never merges windows.

See Also:

Serialized Form

Nested Class Summary

Nested classes/interfaces inherited from class com.google.cloud.dataflow.sdk.transforms.windowing.WindowFn

WindowFn.AssignContext, WindowFn.MergeContext

Constructor Summary

Constructors

Constructor and Description
PartitioningWindowFn()

Method Summary

Methods

Modifier and Type	Method and Description
abstract W	assignWindow(Instant timestamp) Returns the single window to which elements with this timestamp belong.
java.util.Collection<W>	assignWindows(WindowFn.AssignContext c) Given a timestamp and element, returns the set of windows into which it should be placed.

Methods inherited from class com.google.cloud.dataflow.sdk.transforms.windowing.NonMergingWindowFn

mergeWindows

Methods inherited from class com.google.cloud.dataflow.sdk.transforms.windowing.WindowFn

getSideInputWindow, isCompatible, windowCoder

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

PartitioningWindowFn

public PartitioningWindowFn()

Method Detail

assignWindow

public abstract W assignWindow(Instant timestamp)

Returns the single window to which elements with this timestamp belong.

assignWindows

public final java.util.Collection<W> assignWindows(WindowFn.AssignContext c)

Description copied from class: WindowFn

Given a timestamp and element, returns the set of windows into which it should be placed.

Specified by:

assignWindows in class WindowFn<T,W extends BoundedWindow>