org.wattdepot.server.measurement.pruning

Class MeasurementPruner

java.lang.Object

java.util.TimerTask

org.wattdepot.server.measurement.pruning.MeasurementPruner

All Implemented Interfaces:

Runnable

public class MeasurementPruner
extends TimerTask

MeasurementGarbageCollector - Removes measurements from the WattDepot repository that are at a higher frequency sampling rate than desired.

Author:

Cam Moore

Field Summary

Fields

Modifier and Type	Field and Description
static int	PRUNE_WINDOW The window to get the measurements.

Constructor Summary

Constructors

Constructor and Description
MeasurementPruner(ServerProperties properties, String gcdId, String orgId, boolean debug) Create a MeasurementGarbageCollector.

Method Summary

Methods

Modifier and Type	Method and Description
MeasurementPruningDefinition	getDefinition()
List<Measurement>	getMeasurementsToDelete()
WattDepotPersistence	getPersistance()
static void	main(String[] args) Processes the command line arguments and runs the MeasurementGarbageCollector one time.
void	pruneMeasurements() Prunes the measurements.
void	run()

Methods inherited from class java.util.TimerTask

cancel, scheduledExecutionTime

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Field Detail

PRUNE_WINDOW

public static final int PRUNE_WINDOW

The window to get the measurements. Hopefully allows for quicker performance.

See Also:

Constant Field Values

Constructor Detail

MeasurementPruner

public MeasurementPruner(ServerProperties properties,
                 String gcdId,
                 String orgId,
                 boolean debug)
                  throws Exception

Create a MeasurementGarbageCollector.

Parameters:

properties - The ServerProperties that define the type of persistence.

gcdId - The id of the MeasurementPruningDefintion.

orgId - The id of the Organization.

debug - true if want debugging information.

Throws:

Exception - If there is a problem instantiating the WattDepotPersistence.

Method Detail

getDefinition

public MeasurementPruningDefinition getDefinition()

Returns:

the definition

getMeasurementsToDelete

public List<Measurement> getMeasurementsToDelete()
                                          throws IdNotFoundException

Returns:

A list of measurements to garbage collect. They are at a higher sample rate than desired.

Throws:

IdNotFoundException - if there is a problem with the MeasurementPruningDefinition.

getPersistance

public WattDepotPersistence getPersistance()

Returns:

the persistance

main

public static void main(String[] args)
                 throws Exception

Processes the command line arguments and runs the MeasurementGarbageCollector one time.

Parameters:

args - The command line arguments.

Throws:

Exception - if there is a problem.

run

public void run()

Specified by:

run in interface Runnable

Specified by:

run in class TimerTask

pruneMeasurements

public void pruneMeasurements()
                       throws DatatypeConfigurationException,
                              IdNotFoundException

Prunes the measurements.

Throws:

DatatypeConfigurationException - if there is a problem with DateConvert.

IdNotFoundException - if there is a problem with persistence.