org.springframework.xd.analytics.metrics.redis

Class RedisAggregateCounterRepository

java.lang.Object

org.springframework.xd.store.AbstractRedisRepository<Counter,java.lang.String>

org.springframework.xd.analytics.metrics.redis.RedisCounterRepository

org.springframework.xd.analytics.metrics.redis.RedisAggregateCounterRepository

All Implemented Interfaces:

org.springframework.data.repository.CrudRepository<Counter,java.lang.String>, org.springframework.data.repository.PagingAndSortingRepository<Counter,java.lang.String>, org.springframework.data.repository.Repository<Counter,java.lang.String>, AggregateCounterRepository, CounterRepository, MetricRepository<Counter>, DomainRepository<Counter,java.lang.String>, RangeCapableRepository<Counter,java.lang.String>

@Qualifier(value="aggregate")
public class RedisAggregateCounterRepository
extends RedisCounterRepository
implements AggregateCounterRepository

Redis implementation of AggregateCounterRepository. Subclasses and intercepts calls to RedisCounterRepository to also track counts in various redis hashes.

Author:

Eric Bottard, Luke Taylor

Field Summary

Fields

Modifier and Type	Field and Description
protected org.springframework.data.redis.core.HashOperations<java.lang.String,java.lang.String,java.lang.Long>	hashOperations
protected org.springframework.data.redis.core.SetOperations<java.lang.String,java.lang.String>	setOperations

Fields inherited from class org.springframework.xd.analytics.metrics.redis.RedisCounterRepository

longOperations

Fields inherited from class org.springframework.xd.store.AbstractRedisRepository

redisOperations, repoPrefix, zSetOperations

Constructor Summary

Constructors

Constructor and Description
RedisAggregateCounterRepository(org.springframework.data.redis.connection.RedisConnectionFactory redisConnectionFactory)

Method Summary

Methods

Modifier and Type	Method and Description
void	delete(java.lang.String id)
AggregateCount	getCounts(java.lang.String name, int nCounts, AggregateCountResolution resolution) Query function which returns the last 'n' points for a particular resolution.
AggregateCount	getCounts(java.lang.String name, int nCounts, org.joda.time.DateTime endDate, AggregateCountResolution resolution) Queries by requesting a number of points, ending on the given date (inclusive).
AggregateCount	getCounts(java.lang.String name, org.joda.time.Interval interval, AggregateCountResolution resolution) For each query, we need to convert the interval into two variations.
long	increment(java.lang.String name) Increment the given counter by one, creating it if it did not exist.
long	increment(java.lang.String name, long amount, org.joda.time.DateTime dateTime) Increments the named counter by a specific amount for the given instant.

Methods inherited from class org.springframework.xd.analytics.metrics.redis.RedisCounterRepository

decrement, deserialize, deserializeId, increment, keyFor, reset, serialize, serializeId

Methods inherited from class org.springframework.xd.store.AbstractRedisRepository

count, delete, delete, deleteAll, exists, findAll, findAll, findAll, findAll, findAllInRange, findOne, getPrefix, idFromRedisKey, redisKeyFromId, save, save, setPrefix, trackMembership

Methods inherited from class java.lang.Object

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

Methods inherited from interface org.springframework.xd.analytics.metrics.core.CounterRepository

decrement, increment, reset

Methods inherited from interface org.springframework.data.repository.PagingAndSortingRepository

findAll, findAll

Methods inherited from interface org.springframework.data.repository.CrudRepository

count, delete, delete, deleteAll, exists, findAll, findAll, findOne, save, save

Methods inherited from interface org.springframework.xd.store.RangeCapableRepository

findAllInRange

Field Detail

hashOperations

protected org.springframework.data.redis.core.HashOperations<java.lang.String,java.lang.String,java.lang.Long> hashOperations

setOperations

protected org.springframework.data.redis.core.SetOperations<java.lang.String,java.lang.String> setOperations

Constructor Detail

RedisAggregateCounterRepository

public RedisAggregateCounterRepository(org.springframework.data.redis.connection.RedisConnectionFactory redisConnectionFactory)

Parameters:

redisConnectionFactory -

Method Detail

increment

public long increment(java.lang.String name)

Description copied from interface: CounterRepository

Increment the given counter by one, creating it if it did not exist. Implementations which can do this atomically in one operation are encouraged to do so.

Specified by:

increment in interface CounterRepository

Overrides:

increment in class RedisCounterRepository

increment

public long increment(java.lang.String name,
             long amount,
             org.joda.time.DateTime dateTime)

Description copied from interface: AggregateCounterRepository

Increments the named counter by a specific amount for the given instant.

Specified by:

increment in interface AggregateCounterRepository

getCounts

public AggregateCount getCounts(java.lang.String name,
                       int nCounts,
                       AggregateCountResolution resolution)

Description copied from interface: AggregateCounterRepository

Query function which returns the last 'n' points for a particular resolution.

Specified by:

getCounts in interface AggregateCounterRepository

Parameters:

name - the counter to query

nCounts - the number of data points to return

resolution - the resolution at which the data should be returned (minute, hour, day, month)

Returns:

an object containing an indexed array of the aggregate counts for the given query.

getCounts

public AggregateCount getCounts(java.lang.String name,
                       int nCounts,
                       org.joda.time.DateTime endDate,
                       AggregateCountResolution resolution)

Description copied from interface: AggregateCounterRepository

Queries by requesting a number of points, ending on the given date (inclusive). The date may be null to use the current time, thus returning the last nCounts point at the given resolution.

Specified by:

getCounts in interface AggregateCounterRepository

Parameters:

name - the counter to query

nCounts - the number of data points to return

endDate - the end of the query interval (inclusive). Cannot be null.

resolution - the resolution at which the data should be returned (minute, hour, day, month)

Returns:

an object containing an indexed array of the counts .

getCounts

public AggregateCount getCounts(java.lang.String name,
                       org.joda.time.Interval interval,
                       AggregateCountResolution resolution)

For each query, we need to convert the interval into two variations. One is the start and end points rounded to the resolution (used to calculate the number of entries to be returned from the query). The second is the start and end buckets we have to retrieve which may contain entries for the interval. For example, when querying at day resolution, the number of entries is the number of Joda time days between the start (rounded down to a day boundary) and the end plus one day (also rounded down). However, we need load the data from the buckets from the month the start day occurs in to the month end day occurs in. These are then concatenated, using the start day as the start index into the first array, and writing the total number of entries in sequence from that point into the combined result counts array.

Specified by:

getCounts in interface AggregateCounterRepository

Parameters:

name - the counter to query

interval - the time interval to return data for. Includes start and end.

resolution - the resolution at which the data should be returned (minute, hour, day, month)

Returns:

an object containing an indexed array of the aggregate counts for the given query.

delete

public void delete(java.lang.String id)

Specified by:

delete in interface org.springframework.data.repository.CrudRepository<Counter,java.lang.String>

Overrides:

delete in class AbstractRedisRepository<Counter,java.lang.String>