java.lang.Object
org.elasticsearch.compute.operator.DriverStatus
All Implemented Interfaces:
NamedWriteable, Writeable, Task.Status, org.elasticsearch.xcontent.ToXContent, org.elasticsearch.xcontent.ToXContentObject

public class DriverStatus extends Object implements Task.Status
Task.Status reported from a Driver to be reported by the tasks api.
  • Field Details

  • Constructor Details

  • Method Details

    • writeTo

      public void writeTo(StreamOutput out) throws IOException
      Specified by:
      writeTo in interface Writeable
      Throws:
      IOException
    • getWriteableName

      public String getWriteableName()
      Specified by:
      getWriteableName in interface NamedWriteable
    • sessionId

      public String sessionId()
      The session for this driver.
    • taskDescription

      public String taskDescription()
      Description of the task this driver is running. This description should be short and meaningful as a grouping identifier. We use the phase of the query right now: "data", "node_reduce", "final".
    • started

      public long started()
      When this Driver was started.
    • lastUpdated

      public long lastUpdated()
      When this status was generated.
    • cpuNanos

      public long cpuNanos()
      Nanos this Driver has been running on the cpu. Does not include async or waiting time.
    • iterations

      public long iterations()
      The number of times the driver has moved a single page up the chain of operators as far as it'll go.
    • status

      public DriverStatus.Status status()
      The state of the overall driver - queue, starting, running, finished.
    • completedOperators

      public List<OperatorStatus> completedOperators()
      Status of each completed Operator in the driver.
    • sleeps

      public DriverSleeps sleeps()
      Records of the times the driver has slept.
    • activeOperators

      public List<OperatorStatus> activeOperators()
      Status of each active Operator in the driver.
    • toXContent

      public org.elasticsearch.xcontent.XContentBuilder toXContent(org.elasticsearch.xcontent.XContentBuilder builder, org.elasticsearch.xcontent.ToXContent.Params params) throws IOException
      Specified by:
      toXContent in interface org.elasticsearch.xcontent.ToXContent
      Throws:
      IOException
    • equals

      public boolean equals(Object o)
      Overrides:
      equals in class Object
    • hashCode

      public int hashCode()
      Overrides:
      hashCode in class Object
    • toString

      public String toString()
      Overrides:
      toString in class Object
    • documentsFound

      public long documentsFound()
      The number of documents found by this driver.
    • valuesLoaded

      public long valuesLoaded()
      The number of values loaded by this operator.