T - type of elements being windowedW - window typepublic abstract class PartitioningWindowingFn<T,W extends BoundedWindow> extends NonMergingWindowingFn<T,W>
WindowingFn that places each value into exactly one window
based on its timestamp and never merges windows.WindowingFn.AssignContext, WindowingFn.MergeContext| Constructor and Description |
|---|
PartitioningWindowingFn() |
| 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.
|
mergeWindowsisCompatible, windowCoderpublic abstract W assignWindow(Instant timestamp)
public final java.util.Collection<W> assignWindows(WindowingFn.AssignContext c)
WindowingFnassignWindows in class WindowingFn<T,W extends BoundedWindow>