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>

@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, 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, org.joda.time.Interval interval, org.joda.time.DateTimeField resolution) Query function to allow the counts for a specific interval to be retrieved.
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, 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.CrudRepository

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

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,
                       org.joda.time.Interval interval,
                       org.joda.time.DateTimeField resolution)

Description copied from interface: AggregateCounterRepository

Query function to allow the counts for a specific interval to be retrieved.

Specified by:

getCounts in interface AggregateCounterRepository

Parameters:

name - the counter to query

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

resolution - the resolution at which the data should be returned (minutes or hours)

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>