Class State

  • All Implemented Interfaces:
    java.io.Serializable

    @Internal
    public class State
    extends java.lang.Object
    implements java.io.Serializable
    See Also:
    Serialized Form
    • Constructor Detail

      • State

        public State()
    • Method Detail

      • open

        public static State open​(long sequentialId,
                                 long stamp,
                                 java.util.Collection<KeyAttribute> openAttributes)
      • empty

        public static State empty()
      • update

        public State update​(java.util.Collection<KeyAttribute> additionalAttributes)
      • isFinal

        public boolean isFinal()
      • toString

        public java.lang.String toString()
        Overrides:
        toString in class java.lang.Object
      • equals

        public boolean equals​(java.lang.Object o)
        Overrides:
        equals in class java.lang.Object
      • canEqual

        protected boolean canEqual​(java.lang.Object other)
      • hashCode

        public int hashCode()
        Overrides:
        hashCode in class java.lang.Object
      • getSequentialId

        public long getSequentialId()
      • getStamp

        public long getStamp()
      • getInputAttributes

        public java.util.Collection<KeyAttribute> getInputAttributes()
      • getCommittedOutputs

        public java.util.Collection<StreamElement> getCommittedOutputs()