Module org.elasticsearch.compute
Record Class DriverStatus
java.lang.Object
java.lang.Record
org.elasticsearch.compute.operator.DriverStatus
- Record Components:
sessionId- The session for this driver.description- Description of the driver.clusterName- The name of the cluster this driver is running on.nodeName- The name of the node this driver is running on.started- When thisDriverwas started.lastUpdated- When this status was generated.cpuNanos- Nanos thisDriverhas been running on the cpu. Does not include async or waiting time.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.activeOperators- Status of each activeOperatorin the driver.
- All Implemented Interfaces:
NamedWriteable,Writeable,Task.Status,org.elasticsearch.xcontent.ToXContent,org.elasticsearch.xcontent.ToXContentObject
public record DriverStatus(String sessionId, String description, String clusterName, String nodeName, long started, long lastUpdated, long cpuNanos, long iterations, DriverStatus.Status status, List<OperatorStatus> completedOperators, List<OperatorStatus> activeOperators, DriverSleeps sleeps)
extends Record
implements Task.Status
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
ConstructorsConstructorDescriptionDriverStatus(String sessionId, String description, String clusterName, String nodeName, long started, long lastUpdated, long cpuNanos, long iterations, DriverStatus.Status status, List<OperatorStatus> completedOperators, List<OperatorStatus> activeOperators, DriverSleeps sleeps) Creates an instance of aDriverStatusrecord class. -
Method Summary
Modifier and TypeMethodDescriptionReturns the value of theactiveOperatorsrecord component.Returns the value of theclusterNamerecord component.Returns the value of thecompletedOperatorsrecord component.longcpuNanos()Returns the value of thecpuNanosrecord component.Returns the value of thedescriptionrecord component.longThe number of documents found by this driver.final booleanIndicates whether some other object is "equal to" this one.final inthashCode()Returns a hash code value for this object.longReturns the value of theiterationsrecord component.longReturns the value of thelastUpdatedrecord component.nodeName()Returns the value of thenodeNamerecord component.static DriverStatusreadFrom(StreamInput in) Returns the value of thesessionIdrecord component.sleeps()Returns the value of thesleepsrecord component.longstarted()Returns the value of thestartedrecord component.status()Returns the value of thestatusrecord component.toString()Returns a string representation of this record class.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
public DriverStatus(String sessionId, String description, String clusterName, String nodeName, long started, long lastUpdated, long cpuNanos, long iterations, DriverStatus.Status status, List<OperatorStatus> completedOperators, List<OperatorStatus> activeOperators, DriverSleeps sleeps) Creates an instance of aDriverStatusrecord class.- Parameters:
sessionId- the value for thesessionIdrecord componentdescription- the value for thedescriptionrecord componentclusterName- the value for theclusterNamerecord componentnodeName- the value for thenodeNamerecord componentstarted- the value for thestartedrecord componentlastUpdated- the value for thelastUpdatedrecord componentcpuNanos- the value for thecpuNanosrecord componentiterations- the value for theiterationsrecord componentstatus- the value for thestatusrecord componentcompletedOperators- the value for thecompletedOperatorsrecord componentactiveOperators- the value for theactiveOperatorsrecord componentsleeps- the value for thesleepsrecord component
-
-
Method Details
-
readFrom
- Throws:
IOException
-
writeTo
- Specified by:
writeToin interfaceWriteable- Throws:
IOException
-
getWriteableName
- Specified by:
getWriteableNamein interfaceNamedWriteable
-
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
-
toString
Returns a string representation of this record class. The representation contains the name of the class, followed by the name and value of each of the record components. -
documentsFound
public long documentsFound()The number of documents found by this driver. -
valuesLoaded
public long valuesLoaded()The number of values loaded by this operator. -
hashCode
public final int hashCode()Returns a hash code value for this object. The value is derived from the hash code of each of the record components. -
equals
Indicates whether some other object is "equal to" this one. The objects are equal if the other object is of the same class and if all the record components are equal. Reference components are compared withObjects::equals(Object,Object); primitive components are compared with '=='. -
sessionId
Returns the value of thesessionIdrecord component.- Returns:
- the value of the
sessionIdrecord component
-
description
Returns the value of thedescriptionrecord component.- Returns:
- the value of the
descriptionrecord component
-
clusterName
Returns the value of theclusterNamerecord component.- Returns:
- the value of the
clusterNamerecord component
-
nodeName
Returns the value of thenodeNamerecord component.- Returns:
- the value of the
nodeNamerecord component
-
started
public long started()Returns the value of thestartedrecord component.- Returns:
- the value of the
startedrecord component
-
lastUpdated
public long lastUpdated()Returns the value of thelastUpdatedrecord component.- Returns:
- the value of the
lastUpdatedrecord component
-
cpuNanos
public long cpuNanos()Returns the value of thecpuNanosrecord component.- Returns:
- the value of the
cpuNanosrecord component
-
iterations
public long iterations()Returns the value of theiterationsrecord component.- Returns:
- the value of the
iterationsrecord component
-
status
Returns the value of thestatusrecord component.- Returns:
- the value of the
statusrecord component
-
completedOperators
Returns the value of thecompletedOperatorsrecord component.- Returns:
- the value of the
completedOperatorsrecord component
-
activeOperators
Returns the value of theactiveOperatorsrecord component.- Returns:
- the value of the
activeOperatorsrecord component
-
sleeps
Returns the value of thesleepsrecord component.- Returns:
- the value of the
sleepsrecord component
-