Class StreamState

  • All Implemented Interfaces:
    java.io.Serializable

    public class StreamState
    extends java.lang.Object
    implements java.io.Serializable
    Current snapshot of streaming progress.
    See Also:
    Serialized Form
    • Field Detail

      • planId

        public final java.util.UUID planId
      • sessions

        public final java.util.Set<SessionInfo> sessions
    • Constructor Detail

      • StreamState

        public StreamState​(java.util.UUID planId,
                           StreamOperation streamOperation,
                           java.util.Set<SessionInfo> sessions)
    • Method Detail

      • hasFailedSession

        public boolean hasFailedSession()
      • createSummaries

        public java.util.List<SessionSummary> createSummaries()