Interface AppendingState<IN,​OUT>

    • Method Summary

      All Methods Instance Methods Abstract Methods 
      Modifier and Type Method Description
      void add​(IN value)
      Updates the operator state accessible by get() by adding the given value to the list of values.
      OUT get()
      Returns the current value for the state.
      • Methods inherited from interface org.apache.flink.api.common.state.State

        clear
    • Method Detail

      • get

        OUT get()
         throws Exception
        Returns the current value for the state. When the state is not partitioned the returned value is the same for all inputs in a given operator instance. If state partitioning is applied, the value returned depends on the current operator input, as the operator maintains an independent state for each partition.

        NOTE TO IMPLEMENTERS: if the state is empty, then this method should return null.

        Returns:
        The operator state value corresponding to the current input or null if the state is empty.
        Throws:
        Exception - Thrown if the system cannot access the state.
      • add

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

        If null is passed in, the behaviour is undefined (implementation related). TODO: An unified behaviour across all sub-classes.

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