Class IndexerJobStats

java.lang.Object
org.elasticsearch.xpack.core.indexing.IndexerJobStats
All Implemented Interfaces:
Writeable, org.elasticsearch.xcontent.ToXContent, org.elasticsearch.xcontent.ToXContentObject
Direct Known Subclasses:
RollupIndexerJobStats, TransformIndexerStats

public abstract class IndexerJobStats extends Object implements org.elasticsearch.xcontent.ToXContentObject, Writeable
This class holds the runtime statistics of a job. The stats are not used by any internal process and are only for external monitoring/reference. Statistics are not persisted with the job, so if the allocated task is shutdown/restarted on a different node all the stats will reset.
  • Field Details

    • NAME

      public static final org.elasticsearch.xcontent.ParseField NAME
    • numPages

      protected long numPages
    • numInputDocuments

      protected long numInputDocuments
    • numOuputDocuments

      protected long numOuputDocuments
    • numInvocations

      protected long numInvocations
    • indexTime

      protected long indexTime
    • searchTime

      protected long searchTime
    • indexTotal

      protected long indexTotal
    • searchTotal

      protected long searchTotal
    • processingTime

      protected long processingTime
    • processingTotal

      protected long processingTotal
    • indexFailures

      protected long indexFailures
    • searchFailures

      protected long searchFailures
  • Constructor Details

    • IndexerJobStats

      public IndexerJobStats()
    • IndexerJobStats

      public IndexerJobStats(long numPages, long numInputDocuments, long numOuputDocuments, long numInvocations, long indexTime, long searchTime, long processingTime, long indexTotal, long searchTotal, long processingTotal, long indexFailures, long searchFailures)
    • IndexerJobStats

      public IndexerJobStats(StreamInput in) throws IOException
      Throws:
      IOException
  • Method Details

    • getNumPages

      public long getNumPages()
    • getNumDocuments

      public long getNumDocuments()
    • getNumInvocations

      public long getNumInvocations()
    • getOutputDocuments

      public long getOutputDocuments()
    • getIndexFailures

      public long getIndexFailures()
    • getSearchFailures

      public long getSearchFailures()
    • getIndexTime

      public long getIndexTime()
    • getSearchTime

      public long getSearchTime()
    • getProcessingTime

      public long getProcessingTime()
    • getIndexTotal

      public long getIndexTotal()
    • getSearchTotal

      public long getSearchTotal()
    • getProcessingTotal

      public long getProcessingTotal()
    • incrementNumPages

      public void incrementNumPages(long n)
    • incrementNumDocuments

      public void incrementNumDocuments(long n)
    • incrementNumInvocations

      public void incrementNumInvocations(long n)
    • incrementNumOutputDocuments

      public void incrementNumOutputDocuments(long n)
    • incrementIndexingFailures

      public void incrementIndexingFailures()
    • incrementSearchFailures

      public void incrementSearchFailures()
    • markStartIndexing

      public void markStartIndexing()
    • markEndIndexing

      public void markEndIndexing()
    • markStartSearch

      public void markStartSearch()
    • markEndSearch

      public void markEndSearch()
    • markStartProcessing

      public void markStartProcessing()
    • markEndProcessing

      public void markEndProcessing()
    • writeTo

      public void writeTo(StreamOutput out) throws IOException
      Specified by:
      writeTo in interface Writeable
      Throws:
      IOException
    • equals

      public boolean equals(Object other)
      Overrides:
      equals in class Object
    • hashCode

      public int hashCode()
      Overrides:
      hashCode in class Object