Class PendingClusterTask

  • All Implemented Interfaces:
    Writeable

    public class PendingClusterTask
    extends java.lang.Object
    implements Writeable
    • Constructor Detail

      • PendingClusterTask

        public PendingClusterTask​(StreamInput in)
                           throws java.io.IOException
        Throws:
        java.io.IOException
      • PendingClusterTask

        public PendingClusterTask​(long insertOrder,
                                  Priority priority,
                                  Text source,
                                  long timeInQueue,
                                  boolean executing)
    • Method Detail

      • getInsertOrder

        public long getInsertOrder()
      • getPriority

        public Priority getPriority()
      • getSource

        public Text getSource()
      • getTimeInQueueInMillis

        public long getTimeInQueueInMillis()
      • getTimeInQueue

        public TimeValue getTimeInQueue()
      • isExecuting

        public boolean isExecuting()