Class HeartbeatTimeStampEntry


  • public class HeartbeatTimeStampEntry
    extends java.lang.Object
    • Field Summary

      Fields 
      Modifier and Type Field Description
      boolean consumedFromUpstream
      Whether this heartbeat entry was consumed from input or if the system initialized it as a default entry
      boolean readyToServe
      Whether this heartbeat entry is for a partition which is ready to serve
      long timestamp
      The timestamp associated with this entry
    • Constructor Summary

      Constructors 
      Constructor Description
      HeartbeatTimeStampEntry​(long timestamp, boolean readyToServe, boolean consumedFromUpstream)  
    • Method Summary

      • Methods inherited from class java.lang.Object

        clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
    • Field Detail

      • readyToServe

        public final boolean readyToServe
        Whether this heartbeat entry is for a partition which is ready to serve
      • consumedFromUpstream

        public final boolean consumedFromUpstream
        Whether this heartbeat entry was consumed from input or if the system initialized it as a default entry
      • timestamp

        public final long timestamp
        The timestamp associated with this entry
    • Constructor Detail

      • HeartbeatTimeStampEntry

        public HeartbeatTimeStampEntry​(long timestamp,
                                       boolean readyToServe,
                                       boolean consumedFromUpstream)