Module org.elasticsearch.xcore

Package org.elasticsearch.xpack.core.ml.job.process.autodetect.state

Class TimingStats

java.lang.Object

org.elasticsearch.xpack.core.ml.job.process.autodetect.state.TimingStats

All Implemented Interfaces:

Writeable, ToXContent, ToXContentObject

public class TimingStats
extends Object
implements ToXContentObject, Writeable

Stats that give more insight into timing of various operations performed as part of anomaly detection job.

Nested Class Summary

Nested classes/interfaces inherited from interface org.elasticsearch.xcontent.ToXContent

ToXContent.DelegatingMapParams, ToXContent.MapParams, ToXContent.Params

Nested classes/interfaces inherited from interface org.elasticsearch.common.io.stream.Writeable

Writeable.Reader<V>, Writeable.Writer<V>

Field Summary

Fields

Modifier and Type	Field	Description
static final ParseField	AVG_BUCKET_PROCESSING_TIME_MS
static final ParseField	BUCKET_COUNT
static final ParseField	EXPONENTIAL_AVG_BUCKET_PROCESSING_TIME_MS
static final ParseField	EXPONENTIAL_AVG_BUCKET_PROCESSING_TIME_PER_HOUR_MS
static final ParseField	EXPONENTIAL_AVG_CALCULATION_CONTEXT
static final ParseField	MAX_BUCKET_PROCESSING_TIME_MS
static final ParseField	MIN_BUCKET_PROCESSING_TIME_MS
static final ConstructingObjectParser<TimingStats,Void>	PARSER
static final ParseField	TOTAL_BUCKET_PROCESSING_TIME_MS
static final ParseField	TYPE

Fields inherited from interface org.elasticsearch.xcontent.ToXContent

EMPTY, EMPTY_PARAMS

Constructor Summary

Constructors

Constructor	Description
TimingStats(String jobId)
TimingStats(String jobId, long bucketCount, Double minBucketProcessingTimeMs, Double maxBucketProcessingTimeMs, Double avgBucketProcessingTimeMs, Double exponentialAvgBucketProcessingTimeMs, ExponentialAverageCalculationContext exponentialAvgCalculationContext)
TimingStats(StreamInput in)
TimingStats(TimingStats lhs)

Method Summary

Modifier and Type	Method	Description
static String	documentId(String jobId)
boolean	equals(Object o)
Double	getAvgBucketProcessingTimeMs()
long	getBucketCount()
Double	getExponentialAvgBucketProcessingTimeMs()
Double	getExponentialAvgBucketProcessingTimePerHourMs()
String	getJobId()
Double	getMaxBucketProcessingTimeMs()
Double	getMinBucketProcessingTimeMs()
double	getTotalBucketProcessingTimeMs()	Calculates total bucket processing time as a product of the all-time average bucket processing time and the number of buckets.
int	hashCode()
void	setLatestRecordTimestamp(Instant latestRecordTimestamp)
String	toString()
XContentBuilder	toXContent(XContentBuilder builder, ToXContent.Params params)
void	updateStats(double bucketProcessingTimeMs)	Updates the statistics (min, max, avg, exponential avg) for the given data point (bucket processing time).
void	writeTo(StreamOutput out)

Methods inherited from class java.lang.Object

clone, finalize, getClass, notify, notifyAll, wait, wait, wait

Methods inherited from interface org.elasticsearch.xcontent.ToXContentObject

isFragment

Field Details

BUCKET_COUNT

public static final ParseField BUCKET_COUNT

TOTAL_BUCKET_PROCESSING_TIME_MS

public static final ParseField TOTAL_BUCKET_PROCESSING_TIME_MS

MIN_BUCKET_PROCESSING_TIME_MS

public static final ParseField MIN_BUCKET_PROCESSING_TIME_MS

MAX_BUCKET_PROCESSING_TIME_MS

public static final ParseField MAX_BUCKET_PROCESSING_TIME_MS

AVG_BUCKET_PROCESSING_TIME_MS

public static final ParseField AVG_BUCKET_PROCESSING_TIME_MS

EXPONENTIAL_AVG_BUCKET_PROCESSING_TIME_MS

public static final ParseField EXPONENTIAL_AVG_BUCKET_PROCESSING_TIME_MS

EXPONENTIAL_AVG_CALCULATION_CONTEXT

public static final ParseField EXPONENTIAL_AVG_CALCULATION_CONTEXT

EXPONENTIAL_AVG_BUCKET_PROCESSING_TIME_PER_HOUR_MS

public static final ParseField EXPONENTIAL_AVG_BUCKET_PROCESSING_TIME_PER_HOUR_MS

TYPE

public static final ParseField TYPE

PARSER

public static final ConstructingObjectParser<TimingStats,Void> PARSER

Constructor Details

TimingStats

public TimingStats(String jobId,
 long bucketCount,
 @Nullable
 Double minBucketProcessingTimeMs,
 @Nullable
 Double maxBucketProcessingTimeMs,
 @Nullable
 Double avgBucketProcessingTimeMs,
 @Nullable
 Double exponentialAvgBucketProcessingTimeMs,
 ExponentialAverageCalculationContext exponentialAvgCalculationContext)

TimingStats

public TimingStats(String jobId)

TimingStats

public TimingStats(TimingStats lhs)

TimingStats

public TimingStats(StreamInput in)
            throws IOException

Throws:

IOException

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 XContentBuilder toXContent(XContentBuilder builder,
 ToXContent.Params params)
                           throws IOException

Specified by:

toXContent in interface 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