Commit 384873c5 authored by Sören Henning's avatar Sören Henning

renamed top package

parent efbffc58
package anomalydetection;
package teead;
import anomalydetection.measurement.Measurement;
import teead.measurement.Measurement;
import teetime.framework.AbstractProducerStage;
abstract class AbstractMeassurementsGeneratorStage extends AbstractProducerStage<Measurement> {
......
package anomalydetection;
package teead;
import java.io.PrintStream;
import anomalydetection.measurement.AnomalyScoredMeasurement;
import teead.measurement.AnomalyScoredMeasurement;
import teetime.framework.AbstractConsumerStage;
public class AlertPrinterStage extends AbstractConsumerStage<AnomalyScoredMeasurement> {
......
package anomalydetection;
package teead;
import java.io.File;
import java.time.Duration;
......@@ -6,9 +6,9 @@ import java.time.Duration;
import com.datastax.driver.core.Cluster;
import com.datastax.driver.core.Session;
import anomalydetection.aggregation.MeanAggregator;
import anomalydetection.forecast.ARIMAForecaster;
import anomalydetection.storage.CassandraDriver;
import teead.aggregation.MeanAggregator;
import teead.forecast.ARIMAForecaster;
import teead.storage.CassandraDriver;
import teetime.framework.Configuration;
public class AnomalyDetectionConfiguration extends Configuration {
......
package anomalydetection;
package teead;
import java.time.Duration;
import anomalydetection.aggregation.Aggregator;
import anomalydetection.forecast.Forecaster;
import anomalydetection.measurement.AnomalyScoredMeasurement;
import anomalydetection.measurement.Measurement;
import anomalydetection.timeseries.BoundedTimeSeries;
import teead.aggregation.Aggregator;
import teead.forecast.Forecaster;
import teead.measurement.AnomalyScoredMeasurement;
import teead.measurement.Measurement;
import teead.timeseries.BoundedTimeSeries;
import teetime.framework.CompositeStage;
import teetime.framework.InputPort;
import teetime.framework.OutputPort;
......
package anomalydetection;
package teead;
import anomalydetection.anomalyscore.AnomalyScoreCalculator;
import anomalydetection.anomalyscore.SimpleAnomalyScoreCalculator;
import anomalydetection.measurement.AnomalyScoredMeasurement;
import anomalydetection.measurement.ForecastedMeassurement;
import teead.anomalyscore.AnomalyScoreCalculator;
import teead.anomalyscore.SimpleAnomalyScoreCalculator;
import teead.measurement.AnomalyScoredMeasurement;
import teead.measurement.ForecastedMeassurement;
import teetime.stage.basic.AbstractTransformation;
public class AnomalyScoreCalculatorStage extends AbstractTransformation<ForecastedMeassurement, AnomalyScoredMeasurement> {
......
package anomalydetection;
package teead;
import anomalydetection.measurement.Measurement;
import anomalydetection.timeseries.BoundedTimeSeries;
import anomalydetection.timeseries.TimeSeries;
import teead.measurement.Measurement;
import teead.timeseries.BoundedTimeSeries;
import teead.timeseries.TimeSeries;
import teetime.stage.basic.AbstractTransformation;
public class ExtractorStage extends AbstractTransformation<Measurement, TimeSeries> {
......
package anomalydetection;
package teead;
import anomalydetection.forecast.Forecaster;
import anomalydetection.timeseries.EquidistantTimeSeries;
import teead.forecast.Forecaster;
import teead.timeseries.EquidistantTimeSeries;
import teetime.stage.basic.AbstractTransformation;
public class ForecastStage extends AbstractTransformation<EquidistantTimeSeries, Double> {
......
package anomalydetection;
package teead;
import java.io.File;
import java.io.IOException;
......@@ -7,7 +7,7 @@ import com.fasterxml.jackson.core.JsonEncoding;
import com.fasterxml.jackson.core.JsonFactory;
import com.fasterxml.jackson.core.JsonGenerator;
import anomalydetection.measurement.AnomalyScoredMeasurement;
import teead.measurement.AnomalyScoredMeasurement;
import teetime.framework.AbstractConsumerStage;
public class JSONExportStage extends AbstractConsumerStage<AnomalyScoredMeasurement> {
......
package anomalydetection;
package teead;
import anomalydetection.measurement.ForecastedMeassurement;
import anomalydetection.measurement.Measurement;
import anomalydetection.util.AbstractBiCombinerStage;
import teead.measurement.ForecastedMeassurement;
import teead.measurement.Measurement;
import teead.util.AbstractBiCombinerStage;
import teetime.framework.OutputPort;
public class MeasurementForecastDecorationStage extends AbstractBiCombinerStage<Double, Measurement> {
......
package anomalydetection;
package teead;
import java.time.Duration;
import java.time.Instant;
import java.util.function.Function;
import anomalydetection.measurement.Measurement;
import teead.measurement.Measurement;
public class MeasurementGenerator {
......
package anomalydetection;
package teead;
import anomalydetection.measurement.Measurement;
import teead.measurement.Measurement;
public class MeasurementGeneratorStage extends AbstractMeassurementsGeneratorStage {
......
package anomalydetection;
package teead;
import java.time.Duration;
import anomalydetection.aggregation.Aggregator;
import anomalydetection.timeseries.EquidistantTimeSeries;
import anomalydetection.timeseries.TimeSeries;
import teead.aggregation.Aggregator;
import teead.timeseries.EquidistantTimeSeries;
import teead.timeseries.TimeSeries;
import teetime.stage.basic.AbstractTransformation;
public class NormalizerStage extends AbstractTransformation<TimeSeries, EquidistantTimeSeries> {
......
package anomalydetection;
package teead;
import java.io.PrintStream;
import java.util.Formatter;
import anomalydetection.measurement.AnomalyScoredMeasurement;
import teead.measurement.AnomalyScoredMeasurement;
import teetime.framework.AbstractConsumerStage;
public class PrinterStage extends AbstractConsumerStage<AnomalyScoredMeasurement> {
......
package anomalydetection;
package teead;
import java.time.Duration;
import java.time.Instant;
import anomalydetection.measurement.Measurement;
import teead.measurement.Measurement;
public class RealTimeMeasurementGeneratorStage extends AbstractMeassurementsGeneratorStage {
......
package anomalydetection;
package teead;
import java.time.Duration;
import java.time.Instant;
import anomalydetection.aggregation.Aggregator;
import anomalydetection.forecast.Forecaster;
import anomalydetection.storage.StorageDriver;
import anomalydetection.timeseries.BoundedTimeSeries;
import teead.aggregation.Aggregator;
import teead.forecast.Forecaster;
import teead.storage.StorageDriver;
import teead.timeseries.BoundedTimeSeries;
public class StorableAnomalyDetectionStage extends AnomalyDetectionStage {
......
package anomalydetection;
package teead;
import anomalydetection.measurement.AnomalyScoredMeasurement;
import anomalydetection.storage.StorageDriver;
import teead.measurement.AnomalyScoredMeasurement;
import teead.storage.StorageDriver;
import teetime.framework.AbstractConsumerStage;
/**
......
package anomalydetection;
package teead;
import anomalydetection.measurement.AnomalyScoredMeasurement;
import teead.measurement.AnomalyScoredMeasurement;
import teetime.stage.basic.AbstractFilter;
public class ThresholdFilter extends AbstractFilter<AnomalyScoredMeasurement> {
......
package anomalydetection;
package teead;
import anomalydetection.measurement.Measurement;
import anomalydetection.timeseries.BoundedTimeSeries;
import anomalydetection.timeseries.TimeSeries;
import anomalydetection.timeseries.TimeSeriesPoint;
import teead.measurement.Measurement;
import teead.timeseries.BoundedTimeSeries;
import teead.timeseries.TimeSeries;
import teead.timeseries.TimeSeriesPoint;
//TODO Name has to be reconsidered
public class TimeSeriesExtractor {
......
package anomalydetection;
package teead;
import java.time.Duration;
import java.time.Instant;
import anomalydetection.aggregation.Aggregator;
import anomalydetection.timeseries.EquidistantTimeSeries;
import anomalydetection.timeseries.TimeSeries;
import anomalydetection.timeseries.TimeSeriesPoint;
import teead.aggregation.Aggregator;
import teead.timeseries.EquidistantTimeSeries;
import teead.timeseries.TimeSeries;
import teead.timeseries.TimeSeriesPoint;
public class TimeSeriesNormalizer {
......
package anomalydetection.aggregation;
package teead.aggregation;
import anomalydetection.timeseries.TimeSeries;
import teead.timeseries.TimeSeries;
public interface Aggregator {
......
package anomalydetection.aggregation;
package teead.aggregation;
import org.apache.commons.math3.stat.StatUtils;
import anomalydetection.timeseries.TimeSeries;
import teead.timeseries.TimeSeries;
public class GeometricMeanAggregator implements Aggregator {
......
package anomalydetection.aggregation;
package teead.aggregation;
import org.apache.commons.math3.stat.StatUtils;
import anomalydetection.timeseries.TimeSeries;
import teead.timeseries.TimeSeries;
public class MaxAggregator implements Aggregator {
......
package anomalydetection.aggregation;
package teead.aggregation;
import org.apache.commons.math3.stat.StatUtils;
import anomalydetection.timeseries.TimeSeries;
import teead.timeseries.TimeSeries;
public class MeanAggregator implements Aggregator {
......
package anomalydetection.aggregation;
package teead.aggregation;
import org.apache.commons.math3.stat.StatUtils;
import anomalydetection.timeseries.TimeSeries;
import teead.timeseries.TimeSeries;
public class MinAggregator implements Aggregator {
......
package anomalydetection.aggregation;
package teead.aggregation;
import org.apache.commons.math3.stat.StatUtils;
import anomalydetection.timeseries.TimeSeries;
import teead.timeseries.TimeSeries;
public class PercentileAggregator implements Aggregator {
......
package anomalydetection.aggregation;
package teead.aggregation;
import org.apache.commons.math3.stat.StatUtils;
import anomalydetection.timeseries.TimeSeries;
import teead.timeseries.TimeSeries;
public class ProductAggregator implements Aggregator {
......
package anomalydetection.aggregation;
package teead.aggregation;
import org.apache.commons.math3.stat.StatUtils;
import anomalydetection.timeseries.TimeSeries;
import teead.timeseries.TimeSeries;
public class SumAggregator implements Aggregator {
......
package anomalydetection.aggregation;
package teead.aggregation;
import org.apache.commons.math3.stat.StatUtils;
import anomalydetection.timeseries.TimeSeries;
import teead.timeseries.TimeSeries;
public class SumLogAggregator implements Aggregator {
......
package anomalydetection.aggregation;
package teead.aggregation;
import org.apache.commons.math3.stat.StatUtils;
import anomalydetection.timeseries.TimeSeries;
import teead.timeseries.TimeSeries;
public class SumSqAggregator implements Aggregator {
......
package anomalydetection.aggregation;
package teead.aggregation;
import org.apache.commons.math3.stat.StatUtils;
import anomalydetection.timeseries.TimeSeries;
import teead.timeseries.TimeSeries;
public class VarianceAggregator implements Aggregator {
......
package anomalydetection.anomalyscore;
package teead.anomalyscore;
public interface AnomalyScoreCalculator {
......
package anomalydetection.anomalyscore;
package teead.anomalyscore;
public class SimpleAnomalyScoreCalculator implements AnomalyScoreCalculator {
......
package anomalydetection.forecast;
package teead.forecast;
import org.rosuda.REngine.REXPMismatchException;
import org.rosuda.REngine.REngineException;
import anomalydetection.timeseries.EquidistantTimeSeries;
import teead.timeseries.EquidistantTimeSeries;
public class ARIMAForecaster extends AbstractRForecaster {
......
package anomalydetection.forecast;
package teead.forecast;
import org.rosuda.REngine.REXPMismatchException;
import org.rosuda.REngine.REngineException;
import org.rosuda.REngine.Rserve.RConnection;
import org.rosuda.REngine.Rserve.RserveException;
import anomalydetection.timeseries.EquidistantTimeSeries;
import teead.timeseries.EquidistantTimeSeries;
public abstract class AbstractRForecaster implements Forecaster {
......
package anomalydetection.forecast;
package teead.forecast;
import anomalydetection.timeseries.EquidistantTimeSeries;
import teead.timeseries.EquidistantTimeSeries;
public interface Forecaster {
......
package anomalydetection.forecast;
package teead.forecast;
import anomalydetection.timeseries.EquidistantTimeSeries;
import teead.timeseries.EquidistantTimeSeries;
public class MeanForecaster implements Forecaster {
......
package anomalydetection.forecast;
package teead.forecast;
import org.apache.commons.math3.stat.regression.SimpleRegression;
import anomalydetection.timeseries.EquidistantTimeSeries;
import anomalydetection.timeseries.TimeSeriesPoint;
import teead.timeseries.EquidistantTimeSeries;
import teead.timeseries.TimeSeriesPoint;
public class RegressionForecaster implements Forecaster {
......
package anomalydetection.forecast;
package teead.forecast;
import anomalydetection.timeseries.EquidistantTimeSeries;
import anomalydetection.timeseries.TimeSeriesPoint;
import teead.timeseries.EquidistantTimeSeries;
import teead.timeseries.TimeSeriesPoint;
/**
* @author Christian Claus Wiechmann, Sören Henning
......
package anomalydetection.kieker;
package teead.kieker;
import java.util.ArrayDeque;
import java.util.Deque;
......
package anomalydetection.kieker;
package teead.kieker;
public class MonitoringRecord {
......
package anomalydetection.kieker;
package teead.kieker;
import java.time.Instant;
import anomalydetection.measurement.Measurement;
import teead.measurement.Measurement;
import teetime.stage.basic.AbstractTransformation;
public class RecordConverterStage extends AbstractTransformation<MonitoringRecord, Measurement> {
......
package anomalydetection.kieker;
package teead.kieker;
import anomalydetection.util.Filter;
import teead.util.Filter;
import teetime.framework.CompositeStage;
import teetime.framework.InputPort;
import teetime.framework.OutputPort;
......
package anomalydetection.kieker;
package teead.kieker;
import java.util.function.Predicate;
......
package anomalydetection.measurement;
package teead.measurement;
import java.time.Instant;
......
package anomalydetection.storage;
package teead.storage;
import java.time.Instant;
......@@ -9,9 +9,9 @@ import com.datastax.driver.core.querybuilder.Insert;
import com.datastax.driver.core.querybuilder.QueryBuilder;
import com.datastax.driver.core.querybuilder.Select;
import anomalydetection.measurement.AnomalyScoredMeasurement;
import anomalydetection.timeseries.TimeSeries;
import anomalydetection.timeseries.TimeSeriesPoint;
import teead.measurement.AnomalyScoredMeasurement;
import teead.timeseries.TimeSeries;
import teead.timeseries.TimeSeriesPoint;
public class CassandraDriver implements StorageDriver {
......
package anomalydetection.storage;
package teead.storage;
import java.time.Instant;
import anomalydetection.measurement.AnomalyScoredMeasurement;
import anomalydetection.timeseries.TimeSeries;
import teead.measurement.AnomalyScoredMeasurement;
import teead.timeseries.TimeSeries;
public interface StorageDriver {
......
package anomalydetection.timeseries;
package teead.timeseries;
import java.time.Duration;
import java.time.Instant;
......
package anomalydetection.timeseries;
package teead.timeseries;
import java.time.Duration;
import java.time.Instant;
......
package anomalydetection.timeseries;
package teead.timeseries;
import java.util.ArrayDeque;
import java.util.Collection;
......@@ -6,7 +6,7 @@ import java.util.Deque;
import java.util.Iterator;
import java.util.stream.Stream;
import anomalydetection.util.BackwardsIterable;
import teead.util.BackwardsIterable;
/**
*
......
package anomalydetection.timeseries;
package teead.timeseries;
import java.time.Instant;
......
package anomalydetection.util;
package teead.util;
import java.util.LinkedList;
import java.util.Queue;
......
......@@ -14,7 +14,7 @@
* limitations under the License.
***************************************************************************/
package anomalydetection.util;
package teead.util;
import java.util.function.Predicate;
......
Markdown is supported
0% or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment