org.hawkular.metrics.tasks.impl

Class TaskImpl

java.lang.Object

org.hawkular.metrics.tasks.impl.TaskImpl

All Implemented Interfaces:

Task

public class TaskImpl
extends Object
implements Task

Author:

jsanda

Constructor Summary

Constructors

Constructor and Description
TaskImpl(TaskType taskType, String tenantId, org.joda.time.DateTime timeSlice, String target, Set<String> sources, int interval, int window)
TaskImpl(TaskType taskType, String tenantId, org.joda.time.DateTime timeSlice, String target, String source, int interval, int window)

Method Summary

Modifier and Type	Method and Description
boolean	equals(Object o)
int	getInterval() The frequency of the task execution, e.g., five minutes.
Set<String>	getSources() The keys or identifiers of the time series associated with the source data being operated on.
String	getTarget() This is a key or identifier of the time series that is associated with the task.
TaskType	getTaskType()
String	getTenantId()
org.joda.time.DateTime	getTimeSlice() The end time of the time slice for which the task is scheduled.
int	getWindow() Specifies the amount of data to be included.
int	hashCode()
String	toString()

Methods inherited from class java.lang.Object

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

Constructor Detail

TaskImpl

public TaskImpl(TaskType taskType,
                String tenantId,
                org.joda.time.DateTime timeSlice,
                String target,
                String source,
                int interval,
                int window)

TaskImpl

public TaskImpl(TaskType taskType,
                String tenantId,
                org.joda.time.DateTime timeSlice,
                String target,
                Set<String> sources,
                int interval,
                int window)

Method Detail

getTaskType

public TaskType getTaskType()

Specified by:

getTaskType in interface Task

getTenantId

public String getTenantId()

Specified by:

getTenantId in interface Task

getTarget

public String getTarget()

Description copied from interface: Task

This is a key or identifier of the time series that is associated with the task. Consider aggregating metrics or events as an example. Let's say there is a task for computing a 5 minute rollup from raw data. This property should be the key or identifier of the 5 minute rollup time series.

Specified by:

getTarget in interface Task

getSources

public Set<String> getSources()

Description copied from interface: Task

The keys or identifiers of the time series associated with the source data being operated on. There can be one or more sources. Consider aggregating metrics or events as an example. There is a task for computing a 5 minute rollup from raw data. This property identifies the time series of the raw data to be aggregated.

Specified by:

getSources in interface Task

getInterval

public int getInterval()

Description copied from interface: Task

The frequency of the task execution, e.g., five minutes.

Specified by:

getInterval in interface Task

getWindow

public int getWindow()

Description copied from interface: Task

Specifies the amount of data to be included. For an aggregation task that runs every 5 minutes with a window of 15 minutes, the task should query for data from the past 15 minutes using timeSlice as the end time.

Specified by:

getWindow in interface Task

getTimeSlice

public org.joda.time.DateTime getTimeSlice()

Description copied from interface: Task

The end time of the time slice for which the task is scheduled. If a task has an interval of an hour, then the time slice would be 9:00 - 10:00, 10:00 - 11:00, etc. The task is guaranteed to run no earlier than this time.

Specified by:

getTimeSlice in interface Task

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