org.springframework.xd.analytics.metrics.memory

Class InMemoryAggregateCounterRepository

java.lang.Object

org.springframework.xd.store.AbstractRepository<T,ID>

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

org.springframework.xd.analytics.metrics.memory.InMemoryAggregateCounterRepository

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 InMemoryAggregateCounterRepository
extends AbstractInMemoryRepository<Counter,java.lang.String>
implements AggregateCounterRepository

In-memory aggregate counter with minute resolution.

Note that the data is permanently accumulated, so will grow steadily in size until the host process is restarted.

Author:

Luke Taylor, Eric Bottard

Constructor Summary

Constructors

Constructor and Description
InMemoryAggregateCounterRepository()

Method Summary

Methods

Modifier and Type	Method and Description
long	count()
long	decrement(java.lang.String name) Decrement the given counter, creating it if it did not exist.
void	delete(Counter entity)
void	delete(java.lang.String id)
void	deleteAll()
java.lang.Iterable<Counter>	findAll()
Counter	findOne(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 end, 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) 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) Increment the given counter by the specified amount, 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.
protected java.lang.String	keyFor(Counter entity)
void	reset(java.lang.String name) Reset the given counter to zero.
<S extends Counter> S	save(S entity)

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

buildMap, findAll, findAll, findAllInRange, slice

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

delete, exists, findAll, save

Methods inherited from class java.lang.Object

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

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

findAll, findAll

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

delete, exists, findAll, save

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

findAllInRange

Constructor Detail

InMemoryAggregateCounterRepository

public InMemoryAggregateCounterRepository()

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

increment

public long increment(java.lang.String name,
             long amount)

Description copied from interface: CounterRepository

Increment the given counter by the specified amount, 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

decrement

public long decrement(java.lang.String name)

Description copied from interface: CounterRepository

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

Specified by:

decrement in interface CounterRepository

reset

public void reset(java.lang.String name)

Description copied from interface: CounterRepository

Reset the given counter to zero.

Specified by:

reset in interface CounterRepository

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,
                       org.joda.time.Interval interval,
                       AggregateCountResolution 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 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.

getCounts

public AggregateCount getCounts(java.lang.String name,
                       int nCounts,
                       org.joda.time.DateTime end,
                       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

end - 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 .

save

public <S extends Counter> S save(S entity)

Specified by:

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

Overrides:

save in class AbstractInMemoryRepository<Counter,java.lang.String>

keyFor

protected java.lang.String keyFor(Counter entity)

Specified by:

keyFor in class AbstractInMemoryRepository<Counter,java.lang.String>

findOne

public Counter findOne(java.lang.String id)

Specified by:

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

Overrides:

findOne in class AbstractInMemoryRepository<Counter,java.lang.String>

findAll

public java.lang.Iterable<Counter> findAll()

Specified by:

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

Overrides:

findAll in class AbstractInMemoryRepository<Counter,java.lang.String>

count

public long count()

Specified by:

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

Overrides:

count in class AbstractInMemoryRepository<Counter,java.lang.String>

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 AbstractInMemoryRepository<Counter,java.lang.String>

delete

public void delete(Counter entity)

Specified by:

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

Overrides:

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

deleteAll

public void deleteAll()

Specified by:

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

Overrides:

deleteAll in class AbstractInMemoryRepository<Counter,java.lang.String>