java.lang.Object
org.elasticsearch.xpack.core.ml.job.process.autodetect.state.TimingStats
All Implemented Interfaces:
Writeable, org.elasticsearch.xcontent.ToXContent, org.elasticsearch.xcontent.ToXContentObject

public class TimingStats extends Object implements org.elasticsearch.xcontent.ToXContentObject, Writeable
Stats that give more insight into timing of various operations performed as part of anomaly detection job.
  • Field Details

    • BUCKET_COUNT

      public static final org.elasticsearch.xcontent.ParseField BUCKET_COUNT
    • TOTAL_BUCKET_PROCESSING_TIME_MS

      public static final org.elasticsearch.xcontent.ParseField TOTAL_BUCKET_PROCESSING_TIME_MS
    • MIN_BUCKET_PROCESSING_TIME_MS

      public static final org.elasticsearch.xcontent.ParseField MIN_BUCKET_PROCESSING_TIME_MS
    • MAX_BUCKET_PROCESSING_TIME_MS

      public static final org.elasticsearch.xcontent.ParseField MAX_BUCKET_PROCESSING_TIME_MS
    • AVG_BUCKET_PROCESSING_TIME_MS

      public static final org.elasticsearch.xcontent.ParseField AVG_BUCKET_PROCESSING_TIME_MS
    • EXPONENTIAL_AVG_BUCKET_PROCESSING_TIME_MS

      public static final org.elasticsearch.xcontent.ParseField EXPONENTIAL_AVG_BUCKET_PROCESSING_TIME_MS
    • EXPONENTIAL_AVG_CALCULATION_CONTEXT

      public static final org.elasticsearch.xcontent.ParseField EXPONENTIAL_AVG_CALCULATION_CONTEXT
    • EXPONENTIAL_AVG_BUCKET_PROCESSING_TIME_PER_HOUR_MS

      public static final org.elasticsearch.xcontent.ParseField EXPONENTIAL_AVG_BUCKET_PROCESSING_TIME_PER_HOUR_MS
    • TYPE

      public static final org.elasticsearch.xcontent.ParseField TYPE
    • PARSER

      public static final org.elasticsearch.xcontent.ConstructingObjectParser<TimingStats,Void> PARSER
  • Constructor Details

  • Method Details

    • documentId

      public static String documentId(String jobId)
    • getJobId

      public String getJobId()
    • getBucketCount

      public long getBucketCount()
    • getTotalBucketProcessingTimeMs

      public double getTotalBucketProcessingTimeMs()
      Calculates total bucket processing time as a product of the all-time average bucket processing time and the number of buckets.
    • getMinBucketProcessingTimeMs

      public Double getMinBucketProcessingTimeMs()
    • getMaxBucketProcessingTimeMs

      public Double getMaxBucketProcessingTimeMs()
    • getAvgBucketProcessingTimeMs

      public Double getAvgBucketProcessingTimeMs()
    • getExponentialAvgBucketProcessingTimeMs

      public Double getExponentialAvgBucketProcessingTimeMs()
    • getExponentialAvgBucketProcessingTimePerHourMs

      public Double getExponentialAvgBucketProcessingTimePerHourMs()
    • updateStats

      public void updateStats(double bucketProcessingTimeMs)
      Updates the statistics (min, max, avg, exponential avg) for the given data point (bucket processing time).
    • setLatestRecordTimestamp

      public void setLatestRecordTimestamp(Instant latestRecordTimestamp)
    • writeTo

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

      public org.elasticsearch.xcontent.XContentBuilder toXContent(org.elasticsearch.xcontent.XContentBuilder builder, org.elasticsearch.xcontent.ToXContent.Params params) throws IOException
      Specified by:
      toXContent in interface org.elasticsearch.xcontent.ToXContent
      Throws:
      IOException
    • equals

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

      public int hashCode()
      Overrides:
      hashCode in class Object
    • toString

      public String toString()
      Overrides:
      toString in class Object