Class WindowListState<W>

  • All Implemented Interfaces:
    WindowState<W>

    public final class WindowListState<W>
    extends Object
    implements WindowState<W>
    A wrapper of ListState which is easier to update based on window namespace.
    • 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>
      • add

        public void add​(W window,
                        RowData value)
                 throws Exception
        Updates the operator state accessible by #get(W) by adding the given value to the list of values. The next time #get(W) is called (for the same state partition) the returned state will represent the updated list.

        If null is passed in, the state value will remain unchanged.

        Parameters:
        window - The namespace for the state.
        value - The new value for the state.
        Throws:
        Exception - Thrown if the system cannot access the state.