org.springframework.xd.analytics.metrics.redis

Class RedisFieldValueCounterRepository

java.lang.Object

org.springframework.xd.analytics.metrics.redis.RedisFieldValueCounterRepository

All Implemented Interfaces:

org.springframework.data.repository.CrudRepository<FieldValueCounter,java.lang.String>, org.springframework.data.repository.Repository<FieldValueCounter,java.lang.String>, FieldValueCounterRepository, MetricRepository<FieldValueCounter>

public class RedisFieldValueCounterRepository
extends java.lang.Object
implements FieldValueCounterRepository

Constructor Summary

Constructors

Constructor and Description
RedisFieldValueCounterRepository(org.springframework.data.redis.connection.RedisConnectionFactory connectionFactory)
RedisFieldValueCounterRepository(org.springframework.data.redis.connection.RedisConnectionFactory connectionFactory, java.lang.String metricPrefix)

Method Summary

Methods

Modifier and Type	Method and Description
long	count()
void	decrement(java.lang.String counterName, java.lang.String fieldName) Decrement the FieldValueCounter for a given field name by one, creating missing counters.
void	decrement(java.lang.String counterName, java.lang.String fieldName, double score)
void	delete(FieldValueCounter fieldValueCounter)
void	delete(java.lang.Iterable<? extends FieldValueCounter> fvcs)
void	delete(java.lang.String name)
void	deleteAll()
boolean	exists(java.lang.String s)
java.util.List<FieldValueCounter>	findAll()
java.lang.Iterable<FieldValueCounter>	findAll(java.lang.Iterable<java.lang.String> keys)
FieldValueCounter	findOne(java.lang.String name)
protected java.lang.String	getMetricKey(java.lang.String metricName) Provides the key for a named metric.
protected java.util.Map<java.lang.String,java.lang.Double>	getZSetData(java.lang.String counterKey)
void	increment(java.lang.String counterName, java.lang.String fieldName) Increment the FieldValueCounter for a given field name by one, creating missing counters.
void	increment(java.lang.String counterName, java.lang.String fieldName, double score)
void	reset(java.lang.String counterName, java.lang.String fieldName) Reset the FieldValueCounter to zero for the given field name, creating missing counters.
<S extends FieldValueCounter> java.lang.Iterable<S>	save(java.lang.Iterable<S> metrics)
<S extends FieldValueCounter> S	save(S fieldValueCounter)

Methods inherited from class java.lang.Object

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

Constructor Detail

RedisFieldValueCounterRepository

public RedisFieldValueCounterRepository(org.springframework.data.redis.connection.RedisConnectionFactory connectionFactory)

RedisFieldValueCounterRepository

public RedisFieldValueCounterRepository(org.springframework.data.redis.connection.RedisConnectionFactory connectionFactory,
                                java.lang.String metricPrefix)

Method Detail

save

public <S extends FieldValueCounter> S save(S fieldValueCounter)

Specified by:

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

save

public <S extends FieldValueCounter> java.lang.Iterable<S> save(java.lang.Iterable<S> metrics)

Specified by:

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

delete

public void delete(java.lang.String name)

Specified by:

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

delete

public void delete(FieldValueCounter fieldValueCounter)

Specified by:

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

delete

public void delete(java.lang.Iterable<? extends FieldValueCounter> fvcs)

Specified by:

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

findOne

public FieldValueCounter findOne(java.lang.String name)

Specified by:

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

exists

public boolean exists(java.lang.String s)

Specified by:

exists in interface org.springframework.data.repository.CrudRepository<FieldValueCounter,java.lang.String>

findAll

public java.util.List<FieldValueCounter> findAll()

Specified by:

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

findAll

public java.lang.Iterable<FieldValueCounter> findAll(java.lang.Iterable<java.lang.String> keys)

Specified by:

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

count

public long count()

Specified by:

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

deleteAll

public void deleteAll()

Specified by:

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

increment

public void increment(java.lang.String counterName,
             java.lang.String fieldName)

Description copied from interface: FieldValueCounterRepository

Increment the FieldValueCounter for a given field name by one, creating missing counters.

Specified by:

increment in interface FieldValueCounterRepository

Parameters:

counterName - the FieldValueCounter name

fieldName - the name of the field

increment

public void increment(java.lang.String counterName,
             java.lang.String fieldName,
             double score)

decrement

public void decrement(java.lang.String counterName,
             java.lang.String fieldName)

Description copied from interface: FieldValueCounterRepository

Decrement the FieldValueCounter for a given field name by one, creating missing counters.

Specified by:

decrement in interface FieldValueCounterRepository

Parameters:

counterName - the FieldValueCounter name

fieldName - the name of the field

decrement

public void decrement(java.lang.String counterName,
             java.lang.String fieldName,
             double score)

reset

public void reset(java.lang.String counterName,
         java.lang.String fieldName)

Description copied from interface: FieldValueCounterRepository

Reset the FieldValueCounter to zero for the given field name, creating missing counters.

Specified by:

reset in interface FieldValueCounterRepository

Parameters:

counterName - the FieldValueCounter name

fieldName - the name of the field

getMetricKey

protected java.lang.String getMetricKey(java.lang.String metricName)

Provides the key for a named metric. By default this appends the name to the metricPrefix value.

Parameters:

metricName - the name of the metric

Returns:

the redis key under which the metric is stored

getZSetData

protected java.util.Map<java.lang.String,java.lang.Double> getZSetData(java.lang.String counterKey)