org.apache.flink.table.runtime.operators.window.state

Class WindowValueState<W>

java.lang.Object

org.apache.flink.table.runtime.operators.window.state.WindowValueState<W>

All Implemented Interfaces:

WindowState<W>

public final class WindowValueState<W>
extends Object
implements WindowState<W>

A wrapper of ValueState which is easier to update based on window namespace.

Constructor Summary

Constructors

Constructor and Description
WindowValueState(InternalValueState<RowData,W,RowData> windowState)

Method Summary

Modifier and Type	Method and Description
void	clear(W window) Removes the value mapped under current key and the given window.
void	update(W window, RowData value) Update the state with the given value under current key and the given window.
RowData	value(W window) Returns the current value for the state under current key and the given window.

Methods inherited from class java.lang.Object

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

Constructor Detail

WindowValueState

public WindowValueState(InternalValueState<RowData,W,RowData> windowState)

Method Detail

clear

public void clear(W window)

Description copied from interface: WindowState

Removes the value mapped under current key and the given window.

Specified by:

clear in interface WindowState<W>

value

public RowData value(W window)
              throws IOException

Returns the current value for the state under current key and the given window.

Throws:

IOException

update

public void update(W window,
                   RowData value)
            throws IOException

Update the state with the given value under current key and the given window.

Parameters:

window - the window namespace.

value - the new value for the state.

Throws:

IOException