Anand Shah created BAHIR-309:
--------------------------------
Summary: flink-connector-redis add support for ZADD with GT/LT/INCR
Key: BAHIR-309
URL: https://issues.apache.org/jira/browse/BAHIR-309
Project: Bahir
Issue Type: Improvement
Components: Flink Streaming Connectors
Affects Versions: Flink-1.0
Reporter: Anand Shah
Flink connector for Redis
[https://github.com/apache/bahir-flink/tree/master/flink-connector-redis]
already supports redis data structure SortedSet (ZADD)
Many open source users like to leverage additional command description on ZADD
command like GT/LT and INCR for example to off load data replay/late arrival
problem to the Redis.
Example 1: Leaderboard for maximum value
{code:java}
# Normal stream processing recording metric value = 40
ZADD my-leaderboard 40 Player_1 {code}
On late arrival/data correction of data for Player_1 we can do
{code:java}
# Replace metric value only if value is greater, otherwise NO OP.
ZADD my-leaderboard GT 55 Player_1 {code}
Example 2: Leaderboard of total (Sum) of value
{code:java}
# Normal stream processing recording metric value
ZADD my-leaderboard 10 player_2{code}
On late arrival of data, add late metrics to the existing sum metric
{code:java}
# Late arrival metric to be added in original metric
ZADD my-leaderboard INCR 5 player_2{code}
--
This message was sent by Atlassian Jira
(v8.20.10#820010)
