Module org.elasticsearch.compute
Class LimitOperator.Status
java.lang.Object
org.elasticsearch.compute.operator.LimitOperator.Status
- All Implemented Interfaces:
NamedWriteable,VersionedNamedWriteable,Writeable,Operator.Status,org.elasticsearch.xcontent.ToXContent,org.elasticsearch.xcontent.ToXContentObject
- Enclosing class:
LimitOperator
-
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
ConstructorsModifierConstructorDescriptionprotectedStatus(int limit, int limitRemaining, int pagesProcessed, long rowsReceived, long rowsEmitted) protectedStatus(StreamInput in) -
Method Summary
Modifier and TypeMethodDescriptionbooleaninthashCode()intlimit()Total number of position that are emitted by this operator.intCount of pages that have been processed by this operator.intCount of pages that have been processed by this operator.longCount of rows this operator has emitted.longCount of rows this operator has received.toString()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.xcontent.ToXContentObject
isFragment
-
Field Details
-
ENTRY
-
-
Constructor Details
-
Status
protected Status(int limit, int limitRemaining, int pagesProcessed, long rowsReceived, long rowsEmitted) -
Status
- Throws:
IOException
-
-
Method Details
-
writeTo
- Specified by:
writeToin interfaceWriteable- Throws:
IOException
-
getWriteableName
- Specified by:
getWriteableNamein interfaceNamedWriteable- Specified by:
getWriteableNamein interfaceVersionedNamedWriteable
-
limit
public int limit()Total number of position that are emitted by this operator. -
limitRemaining
public int limitRemaining()Count of pages that have been processed by this operator. -
pagesProcessed
public int pagesProcessed()Count of pages that have been processed by this operator. -
rowsReceived
public long rowsReceived()Count of rows this operator has received. -
rowsEmitted
public long rowsEmitted()Count of rows this operator has emitted. -
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
-
getMinimalSupportedVersion
- Specified by:
getMinimalSupportedVersionin interfaceVersionedNamedWriteable
-