java.lang.Object
org.elasticsearch.compute.operator.DriverStatus
- All Implemented Interfaces:
NamedWriteable,Writeable,Task.Status,org.elasticsearch.xcontent.ToXContent,org.elasticsearch.xcontent.ToXContentObject
Task.Status reported from a Driver to be reported by the tasks api.-
Nested Class Summary
Nested ClassesNested classes/interfaces inherited from interface org.elasticsearch.xcontent.ToXContent
org.elasticsearch.xcontent.ToXContent.DelegatingMapParams, org.elasticsearch.xcontent.ToXContent.MapParams, org.elasticsearch.xcontent.ToXContent.ParamsNested classes/interfaces inherited from interface org.elasticsearch.common.io.stream.Writeable
Writeable.Reader<V>, Writeable.Writer<V> -
Field Summary
FieldsFields inherited from interface org.elasticsearch.xcontent.ToXContent
EMPTY, EMPTY_PARAMS -
Constructor Summary
Constructors -
Method Summary
Modifier and TypeMethodDescriptionStatus of each activeOperatorin the driver.Status of each completedOperatorin the driver.longcpuNanos()Nanos thisDriverhas been running on the cpu.longThe number of documents found by this driver.booleaninthashCode()longThe number of times the driver has moved a single page up the chain of operators as far as it'll go.longWhen this status was generated.The session for this driver.sleeps()Records of the times the driver has slept.longstarted()When thisDriverwas started.status()The state of the overall driver - queue, starting, running, finished.Description of the task this driver is running.toString()org.elasticsearch.xcontent.XContentBuildertoXContent(org.elasticsearch.xcontent.XContentBuilder builder, org.elasticsearch.xcontent.ToXContent.Params params) longThe number of values loaded by this operator.voidwriteTo(StreamOutput out) Methods inherited from class java.lang.Object
clone, finalize, getClass, notify, notifyAll, wait, wait, waitMethods inherited from interface org.elasticsearch.xcontent.ToXContentObject
isFragment
-
Field Details
-
ENTRY
-
-
Constructor Details
-
DriverStatus
- Throws:
IOException
-
-
Method Details
-
writeTo
- Specified by:
writeToin interfaceWriteable- Throws:
IOException
-
getWriteableName
- Specified by:
getWriteableNamein interfaceNamedWriteable
-
sessionId
The session for this driver. -
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 thisDriverwas started. -
lastUpdated
public long lastUpdated()When this status was generated. -
cpuNanos
public long cpuNanos()Nanos thisDriverhas 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
The state of the overall driver - queue, starting, running, finished. -
completedOperators
Status of each completedOperatorin the driver. -
sleeps
Records of the times the driver has slept. -
activeOperators
Status of each activeOperatorin the driver. -
toXContent
public org.elasticsearch.xcontent.XContentBuilder toXContent(org.elasticsearch.xcontent.XContentBuilder builder, org.elasticsearch.xcontent.ToXContent.Params params) throws IOException - Specified by:
toXContentin interfaceorg.elasticsearch.xcontent.ToXContent- Throws:
IOException
-
equals
-
hashCode
public int hashCode() -
toString
-
documentsFound
public long documentsFound()The number of documents found by this driver. -
valuesLoaded
public long valuesLoaded()The number of values loaded by this operator.
-