Module org.elasticsearch.xcore
Class TransformIndexerStats
java.lang.Object
org.elasticsearch.xpack.core.indexing.IndexerJobStats
org.elasticsearch.xpack.core.transform.transforms.TransformIndexerStats
- All Implemented Interfaces:
Writeable,ToXContent,ToXContentObject
-
Nested Class Summary
Nested classes/interfaces inherited from interface org.elasticsearch.xcontent.ToXContent
ToXContent.DelegatingMapParams, ToXContent.MapParams, ToXContent.ParamsNested classes/interfaces inherited from interface org.elasticsearch.common.io.stream.Writeable
Writeable.Reader<V>, Writeable.Writer<V> -
Field Summary
FieldsModifier and TypeFieldDescriptionstatic final ParseFieldstatic final ParseFieldstatic final ParseFieldstatic final ParseFieldstatic final ParseFieldstatic final ParseFieldstatic final ParseFieldstatic final Stringstatic final ParseFieldstatic final ParseFieldstatic final ParseFieldstatic final ParseFieldstatic final ParseFieldstatic final ParseFieldstatic final ParseFieldstatic final ParseFieldstatic final ParseFieldstatic final ParseFieldFields inherited from class org.elasticsearch.xpack.core.indexing.IndexerJobStats
indexFailures, indexTime, indexTotal, numInputDocuments, numInvocations, numOuputDocuments, numPages, processingTime, processingTotal, searchFailures, searchTime, searchTotalFields inherited from interface org.elasticsearch.xcontent.ToXContent
EMPTY, EMPTY_PARAMS -
Constructor Summary
ConstructorsConstructorDescriptionCreate with all stats set to zeroTransformIndexerStats(long numPages, long numInputDocuments, long numOutputDocuments, long numDeletedDocuments, long numInvocations, long indexTime, long searchTime, long processingTime, long deleteTime, long indexTotal, long searchTotal, long processingTotal, long indexFailures, long searchFailures, double expAvgCheckpointDurationMs, double expAvgDocumentsIndexed, double expAvgDocumentsProcessed) -
Method Summary
Modifier and TypeMethodDescriptionbooleanstatic TransformIndexerStatsfromXContent(XContentParser parser) longdoubledoubledoublelonginthashCode()voidincrementCheckpointExponentialAverages(long checkpointDurationMs, long docsIndexed, long docsProcessed) voidincrementNumDeletedDocuments(long n) voidvoidtoString()toXContent(XContentBuilder builder, ToXContent.Params params) voidwriteTo(StreamOutput out) Methods inherited from class org.elasticsearch.xpack.core.indexing.IndexerJobStats
getIndexFailures, getIndexTime, getIndexTotal, getNumDocuments, getNumInvocations, getNumPages, getOutputDocuments, getProcessingTime, getProcessingTotal, getSearchFailures, getSearchTime, getSearchTotal, incrementIndexingFailures, incrementNumDocuments, incrementNumInvocations, incrementNumOutputDocuments, incrementNumPages, incrementSearchFailures, markEndIndexing, markEndProcessing, markEndSearch, markStartIndexing, markStartProcessing, markStartSearchMethods inherited from class java.lang.Object
clone, finalize, getClass, notify, notifyAll, wait, wait, waitMethods inherited from interface org.elasticsearch.xcontent.ToXContentObject
isFragment
-
Field Details
-
NAME
- See Also:
-
NUM_PAGES
-
NUM_INPUT_DOCUMENTS
-
NUM_OUTPUT_DOCUMENTS
-
NUM_DELETED_DOCUMENTS
-
NUM_INVOCATIONS
-
INDEX_TIME_IN_MS
-
SEARCH_TIME_IN_MS
-
PROCESSING_TIME_IN_MS
-
DELETE_TIME_IN_MS
-
INDEX_TOTAL
-
SEARCH_TOTAL
-
PROCESSING_TOTAL
-
SEARCH_FAILURES
-
INDEX_FAILURES
-
EXPONENTIAL_AVG_CHECKPOINT_DURATION_MS
-
EXPONENTIAL_AVG_DOCUMENTS_INDEXED
-
EXPONENTIAL_AVG_DOCUMENTS_PROCESSED
-
-
Constructor Details
-
TransformIndexerStats
public TransformIndexerStats()Create with all stats set to zero -
TransformIndexerStats
public TransformIndexerStats(long numPages, long numInputDocuments, long numOutputDocuments, long numDeletedDocuments, long numInvocations, long indexTime, long searchTime, long processingTime, long deleteTime, long indexTotal, long searchTotal, long processingTotal, long indexFailures, long searchFailures, double expAvgCheckpointDurationMs, double expAvgDocumentsIndexed, double expAvgDocumentsProcessed) -
TransformIndexerStats
-
TransformIndexerStats
- Throws:
IOException
-
-
Method Details
-
writeTo
- Specified by:
writeToin interfaceWriteable- Overrides:
writeToin classIndexerJobStats- Throws:
IOException
-
toXContent
public XContentBuilder toXContent(XContentBuilder builder, ToXContent.Params params) throws IOException - Throws:
IOException
-
getDeleteTime
public long getDeleteTime() -
getNumDeletedDocuments
public long getNumDeletedDocuments() -
getExpAvgCheckpointDurationMs
public double getExpAvgCheckpointDurationMs() -
getExpAvgDocumentsIndexed
public double getExpAvgDocumentsIndexed() -
getExpAvgDocumentsProcessed
public double getExpAvgDocumentsProcessed() -
incrementNumDeletedDocuments
public void incrementNumDeletedDocuments(long n) -
markStartDelete
public void markStartDelete() -
markEndDelete
public void markEndDelete() -
incrementCheckpointExponentialAverages
public void incrementCheckpointExponentialAverages(long checkpointDurationMs, long docsIndexed, long docsProcessed) -
equals
- Overrides:
equalsin classIndexerJobStats
-
hashCode
public int hashCode()- Overrides:
hashCodein classIndexerJobStats
-
toString
-
fromXContent
-