Class 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 Description
      WindowValueState​(org.apache.flink.runtime.state.internal.InternalValueState<org.apache.flink.table.data.RowData,​W,​org.apache.flink.table.data.RowData> windowState)  
    • Constructor Detail

      • WindowValueState

        public WindowValueState​(org.apache.flink.runtime.state.internal.InternalValueState<org.apache.flink.table.data.RowData,​W,​org.apache.flink.table.data.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 org.apache.flink.table.data.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,
                           org.apache.flink.table.data.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