public class RedisHLLMethods
extends io.toro.martini.redis.RedisBaseMethods
Constructor and Description |
---|
RedisHLLMethods(DataSourceManager dataSourceManager) |
Modifier and Type | Method and Description |
---|---|
static Long |
pfadd(String connectionName,
Object key,
GloopExecutionContext context,
Object... values)
Adds the specified elements to the specified HyperLogLog.
|
static Future<Long> |
pfaddAsync(String connectionName,
Object key,
GloopExecutionContext context,
Object... values)
Asynchronously adds the specified elements to the specified hyperLogLog.
|
static Long |
pfcount(String connectionName,
GloopExecutionContext context,
Object... keys)
Return the approximated cardinality of the set(s) observed by the HyperLogLog at key(s).
|
static Future<Long> |
pfcountAsync(String connectionName,
GloopExecutionContext context,
Object... keys)
Asynchronously return the approximated cardinality of the set(s) observed by the hyperLogLog at key(s).
|
static String |
pfmerge(String connectionName,
Object destkey,
GloopExecutionContext context,
Object... sourcekeys)
Merge N different HyperLogLogs into a single one.
|
static Future<String> |
pfmergeAsync(String connectionName,
Object destkey,
GloopExecutionContext context,
Object... sourcekeys)
Asynchronously merge n different hyperLogLogs into a single one.
|
@Autowired RedisHLLMethods(DataSourceManager dataSourceManager)
@GloopParameter(name="redisPfaddOutput") public static Long pfadd(@GloopParameter(allowNull=false) String connectionName, @GloopParameter(allowNull=false) Object key, GloopExecutionContext context, @GloopParameter(allowNull=false) Object... values)
connectionName
- The Martini Runtime Redis connection pool namekey
- the keyvalues
- the values@GloopParameter(name="redisFuturePfaddOutput") public static Future<Long> pfaddAsync(@GloopParameter(allowNull=false) String connectionName, @GloopParameter(allowNull=false) Object key, GloopExecutionContext context, @GloopParameter(allowNull=false) Object... values)
connectionName
- The Martini Runtime Redis connection pool namekey
- the keyvalues
- the values@GloopParameter(name="redisPfmergeOutput") public static String pfmerge(@GloopParameter(allowNull=false) String connectionName, @GloopParameter(allowNull=false) Object destkey, GloopExecutionContext context, @GloopParameter(allowNull=false) Object... sourcekeys)
connectionName
- The Martini Runtime Redis connection pool namedestkey
- the destination keysourcekeys
- the source keyOK
.@GloopParameter(name="redisFuturePfmergeOutput") public static Future<String> pfmergeAsync(@GloopParameter(allowNull=false) String connectionName, @GloopParameter(allowNull=false) Object destkey, GloopExecutionContext context, @GloopParameter(allowNull=false) Object... sourcekeys)
connectionName
- The Martini Runtime Redis connection pool namedestkey
- the destination keysourcekeys
- the source keyoK
.@GloopParameter(name="redisPfcountOutput") public static Long pfcount(@GloopParameter(allowNull=false) String connectionName, GloopExecutionContext context, @GloopParameter(allowNull=false) Object... keys)
connectionName
- The Martini Runtime Redis connection pool namekeys
- the keysPFADD
.@GloopParameter(name="redisFuturePfcountOutput") public static Future<Long> pfcountAsync(@GloopParameter(allowNull=false) String connectionName, GloopExecutionContext context, @GloopParameter(allowNull=false) Object... keys)
connectionName
- The Martini Runtime Redis connection pool namekeys
- the keyspFADD
.Copyright © 2023. All rights reserved.