Package org.apache.flink.table.runtime.operators.window.internal

Class PanedWindowProcessFunction<K,W extends Window>

java.lang.Object

org.apache.flink.table.runtime.operators.window.internal.InternalWindowProcessFunction<K,W>

org.apache.flink.table.runtime.operators.window.internal.PanedWindowProcessFunction<K,W>

Type Parameters:

W - The type of Window that assigner assigns.

All Implemented Interfaces:

Serializable

public class PanedWindowProcessFunction<K,W extends Window>
extends InternalWindowProcessFunction<K,W>

The implementation of InternalWindowProcessFunction for PanedWindowAssigner.

See Also:

Serialized Form

Nested Class Summary

Nested classes/interfaces inherited from class org.apache.flink.table.runtime.operators.window.internal.InternalWindowProcessFunction

InternalWindowProcessFunction.Context<K,W extends Window>

Field Summary

Fields inherited from class org.apache.flink.table.runtime.operators.window.internal.InternalWindowProcessFunction

allowedLateness, ctx, windowAggregator

Constructor Summary

Constructors

Constructor	Description
PanedWindowProcessFunction(PanedWindowAssigner<W> windowAssigner, NamespaceAggsHandleFunctionBase<W> windowAggregator, long allowedLateness)

Method Summary

Modifier and Type	Method	Description
Collection<W>	assignActualWindows(org.apache.flink.table.data.RowData inputRow, long timestamp)	Assigns the input element into the actual windows which the Trigger should trigger on.
Collection<W>	assignStateNamespace(org.apache.flink.table.data.RowData inputRow, long timestamp)	Assigns the input element into the state namespace which the input element should be accumulated/retracted into.
void	cleanWindowIfNeeded(W window, long currentTime)	Cleans the given window if needed.
void	prepareAggregateAccumulatorForEmit(W window)	Prepares the accumulator of the given window before emit the final result.

Methods inherited from class org.apache.flink.table.runtime.operators.window.internal.InternalWindowProcessFunction

close, isCleanupTime, isWindowLate, open

Methods inherited from class java.lang.Object

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

Constructor Detail

PanedWindowProcessFunction

public PanedWindowProcessFunction(PanedWindowAssigner<W> windowAssigner,
                                  NamespaceAggsHandleFunctionBase<W> windowAggregator,
                                  long allowedLateness)

Method Detail

assignActualWindows

public Collection<W> assignActualWindows(org.apache.flink.table.data.RowData inputRow,
                                         long timestamp)
                                  throws Exception

Description copied from class: InternalWindowProcessFunction

Assigns the input element into the actual windows which the Trigger should trigger on.

Specified by:

assignActualWindows in class InternalWindowProcessFunction<K,W extends Window>

Parameters:

inputRow - the input element

timestamp - the timestamp of the element or the processing time (depends on the type of assigner)

Returns:

the actual windows

Throws:

Exception

assignStateNamespace

public Collection<W> assignStateNamespace(org.apache.flink.table.data.RowData inputRow,
                                          long timestamp)
                                   throws Exception

Description copied from class: InternalWindowProcessFunction

Assigns the input element into the state namespace which the input element should be accumulated/retracted into.

Specified by:

assignStateNamespace in class InternalWindowProcessFunction<K,W extends Window>

Parameters:

inputRow - the input element

timestamp - the timestamp of the element or the processing time (depends on the type of assigner)

Returns:

the state namespace

Throws:

Exception

prepareAggregateAccumulatorForEmit

public void prepareAggregateAccumulatorForEmit(W window)
                                        throws Exception

Description copied from class: InternalWindowProcessFunction

Prepares the accumulator of the given window before emit the final result. The accumulator is stored in the state or will be created if there is no corresponding accumulator in state.

Specified by:

prepareAggregateAccumulatorForEmit in class InternalWindowProcessFunction<K,W extends Window>

Parameters:

window - the window

Throws:

Exception

cleanWindowIfNeeded

public void cleanWindowIfNeeded(W window,
                                long currentTime)
                         throws Exception

Description copied from class: InternalWindowProcessFunction

Cleans the given window if needed.

Specified by:

cleanWindowIfNeeded in class InternalWindowProcessFunction<K,W extends Window>

Parameters:

window - the window to cleanup

currentTime - the current timestamp

Throws:

Exception