Class StreamingLookupFromIndexOperator.StreamingLookupStatus
java.lang.Object
org.elasticsearch.xpack.esql.enrich.StreamingLookupFromIndexOperator.StreamingLookupStatus
- All Implemented Interfaces:
NamedWriteable,VersionedNamedWriteable,Writeable,Operator.Status,org.elasticsearch.xcontent.ToXContent,org.elasticsearch.xcontent.ToXContentObject
- Enclosing class:
StreamingLookupFromIndexOperator
public static class StreamingLookupFromIndexOperator.StreamingLookupStatus
extends Object
implements Operator.Status
Status for StreamingLookupFromIndexOperator.
-
Nested Class Summary
Nested 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
ConstructorsConstructorDescriptionStreamingLookupStatus(long pagesReceived, long pagesEmitted, long rowsReceived, long rowsEmitted, long planningNanos, long processNanos, Map<String, Set<String>> planToWorkers) -
Method Summary
Modifier and TypeMethodDescriptionbooleaninthashCode()longlonglonglonglonglongtoString()org.elasticsearch.xcontent.XContentBuildertoXContent(org.elasticsearch.xcontent.XContentBuilder builder, org.elasticsearch.xcontent.ToXContent.Params params) voidwriteTo(StreamOutput out) Methods inherited from class java.lang.Object
clone, finalize, getClass, notify, notifyAll, wait, wait, waitMethods inherited from interface org.elasticsearch.compute.operator.Operator.Status
documentsFound, valuesLoadedMethods inherited from interface org.elasticsearch.xcontent.ToXContentObject
isFragmentMethods inherited from interface org.elasticsearch.common.io.stream.VersionedNamedWriteable
supportsVersion
-
Field Details
-
ENTRY
-
-
Constructor Details
-
StreamingLookupStatus
-
StreamingLookupStatus
- Throws:
IOException
-
-
Method Details
-
writeTo
- Specified by:
writeToin interfaceWriteable- Throws:
IOException
-
getWriteableName
- Specified by:
getWriteableNamein interfaceNamedWriteable- Specified by:
getWriteableNamein interfaceVersionedNamedWriteable
-
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
-
pagesReceived
public long pagesReceived() -
pagesEmitted
public long pagesEmitted() -
rowsReceived
public long rowsReceived() -
rowsEmitted
public long rowsEmitted() -
planningNanos
public long planningNanos() -
processNanos
public long processNanos() -
planToWorkers
-
getMinimalSupportedVersion
- Specified by:
getMinimalSupportedVersionin interfaceVersionedNamedWriteable
-
equals
-
hashCode
public int hashCode() -
toString
-