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

Class PartitioningWindowingFn<T,W extends BoundedWindow>

java.lang.Object

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

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

com.google.cloud.dataflow.sdk.transforms.windowing.PartitioningWindowingFn<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 PartitioningWindowingFn<T,W extends BoundedWindow>
extends NonMergingWindowingFn<T,W>

A WindowingFn 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.WindowingFn

WindowingFn.AssignContext, WindowingFn.MergeContext

Constructor Summary

Constructors

Constructor and Description
PartitioningWindowingFn()

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(WindowingFn.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.NonMergingWindowingFn

mergeWindows

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

isCompatible, windowCoder

Methods inherited from class java.lang.Object

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

Constructor Detail

PartitioningWindowingFn

public PartitioningWindowingFn()

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(WindowingFn.AssignContext c)

Description copied from class: WindowingFn

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

Specified by:

assignWindows in class WindowingFn<T,W extends BoundedWindow>