org.hawkular.metrics.tasks.api

Class TaskType

java.lang.Object

org.hawkular.metrics.tasks.api.TaskType

public class TaskType
extends Object

Tasks are grouped by type, and execution order is also determined by type. If there are types A, B, C, then for a given time slice all tasks of type A are executed followed by tasks of type B and finally tasks of type C are executed. The task type specifies the granularity of partitioning of tasks in the database. It also provides a factory function that produces a function to execute tasks.

Author:

jsanda

Constructor Summary

Constructors

Constructor and Description
TaskType()

Method Summary

Modifier and Type	Method and Description
Task	createTask(String target, String source, int interval, int window) A factory method for creating tasks of this type.
boolean	equals(Object o)
Supplier<Consumer<Task>>	getFactory() A function that produces functions that carry out task execution.
String	getName() The task type name which must be unique among task types.
int	getSegmentOffsets() Tasks are associated with leases.
int	getSegments() The number of partitions in the database to use for storing tasks.
int	hashCode()
TaskType	setFactory(Supplier<Consumer<Task>> factory)
TaskType	setName(String name)
TaskType	setSegmentOffsets(int segmentOffsets)
TaskType	setSegments(int segments)

Methods inherited from class java.lang.Object

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

Constructor Detail

TaskType

public TaskType()

Method Detail

getName

public String getName()

The task type name which must be unique among task types.

setName

public TaskType setName(String name)

getFactory

public Supplier<Consumer<Task>> getFactory()

A function that produces functions that carry out task execution.

setFactory

public TaskType setFactory(Supplier<Consumer<Task>> factory)

getSegments

public int getSegments()

The number of partitions in the database to use for storing tasks. The segment is determined by, task.target.hashCode() % segments

setSegments

public TaskType setSegments(int segments)

getSegmentOffsets

public int getSegmentOffsets()

Tasks are associated with leases. A client needs to acquire a lease before it can execute the tasks associated with the lease. This property specifies how many tasks in terms of segments are associated with a lease. Let's say that we have 100 segments and 10 segment offsets. This means that there are 10 task segments per lease. When a client acquires a lease, the client will then execute the tasks in each of those segments.

TODO Come up with a more descriptive name

setSegmentOffsets

public TaskType setSegmentOffsets(int segmentOffsets)

createTask

public Task createTask(String target,
                       String source,
                       int interval,
                       int window)

A factory method for creating tasks of this type.

Parameters:

target - Identifier or key of the entity or time series associated with the task

source - Identifiers or keys of the time series that provide input data for the task

interval - Specifies the frequency of execution in minutes

window - Specifies the amount of data to include in minutes

Returns:

A Task

equals

public boolean equals(Object o)

Overrides:

equals in class Object

hashCode

public int hashCode()

Overrides:

hashCode in class Object