PanedWindowAssigner (Flink : Table : Runtime 1.18.1-cp2 API)

java.lang.Object
- org.apache.flink.table.runtime.operators.window.assigners.WindowAssigner<W>
- - org.apache.flink.table.runtime.operators.window.assigners.PanedWindowAssigner<W>

Type Parameters:

W - The type of Window that this assigner assigns.

All Implemented Interfaces:

Serializable

Direct Known Subclasses:

CumulativeWindowAssigner, SlidingWindowAssigner
```
public abstract class PanedWindowAssigner<W extends Window>
extends WindowAssigner<W>
```
A WindowAssigner that window can be split into panes.

See Also:

Serialized Form

Constructor Summary

Constructors
Constructor Description

PanedWindowAssigner()

Method Summary

All Methods Instance Methods Abstract Methods
Modifier and Type	Method	Description
`abstract W`	`assignPane(Object element, long timestamp)`	Given the timestamp and element, returns the pane into which it should be placed.
`abstract W`	`getLastWindow(W pane)`	Gets the last window which the pane belongs to.
`abstract Iterable<W>`	`splitIntoPanes(W window)`	Splits the given window into panes collection.

Methods inherited from class org.apache.flink.table.runtime.operators.window.assigners.WindowAssigner
assignWindows, getWindowSerializer, isEventTime, open, toString

Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait

- Constructor Detail
  - PanedWindowAssigner
```
public PanedWindowAssigner()
```
- Method Detail
  - assignPane
```
public abstract W assignPane(Object element,
                             long timestamp)
```
    Given the timestamp and element, returns the pane into which it should be placed.
    
    Parameters:
    
    element - The element to which windows should be assigned.
    
    timestamp - The timestamp of the element when WindowAssigner.isEventTime() returns true, or the current system time when WindowAssigner.isEventTime() returns false.
  - splitIntoPanes
```
public abstract Iterable<W> splitIntoPanes(W window)
```
    Splits the given window into panes collection.
    
    Parameters:
    
    window - the window to be split.
    
    Returns:
    
    the panes iterable
  - getLastWindow
```
public abstract W getLastWindow(W pane)
```
    Gets the last window which the pane belongs to.