public class SimpleExponentialSmoothing extends Object
Modifier and Type | Method and Description |
---|---|
static SimpleExponentialSmoothing |
createForecast(long timeConstant,
int skipCnt,
long stagnatedWindow,
long timeStamp) |
double |
getForecast() |
AtomicReference<org.apache.hadoop.mapreduce.v2.app.speculate.forecast.SimpleExponentialSmoothing.ForecastRecord> |
getForecastRefEntry() |
double |
getRawData() |
double |
getSSE() |
long |
getStartTime() |
long |
getTimeStamp() |
void |
incorporateReading(long timeStamp,
double currRawData) |
boolean |
isDataStagnated(long timeStamp)
checks if the task is hanging up.
|
boolean |
isDefaultForecast(double value) |
boolean |
isErrorWithinBound(double bound) |
String |
toString() |
public static SimpleExponentialSmoothing createForecast(long timeConstant, int skipCnt, long stagnatedWindow, long timeStamp)
public boolean isDataStagnated(long timeStamp)
timeStamp
- current time of the scan.public void incorporateReading(long timeStamp, double currRawData)
public double getForecast()
public boolean isDefaultForecast(double value)
public double getSSE()
public boolean isErrorWithinBound(double bound)
public double getRawData()
public long getTimeStamp()
public long getStartTime()
public AtomicReference<org.apache.hadoop.mapreduce.v2.app.speculate.forecast.SimpleExponentialSmoothing.ForecastRecord> getForecastRefEntry()
Copyright © 2008–2024 Apache Software Foundation. All rights reserved.