miki haiat created BAHIR-155:
--------------------------------
Summary: Add expire to redis sink
Key: BAHIR-155
URL: https://issues.apache.org/jira/browse/BAHIR-155
Project: Bahir
Issue Type: Wish
Components: Flink Streaming Connectors
Affects Versions: Flink-1.0
Reporter: miki haiat
Priority: Critical
Fix For: Flink-1.0
I have a scenario that im collection some MD and aggregate the result by time
.
for example Each HSET of each window can create different values
by adding expiry i can guarantee that the key is holding only the current
window values
im thinking to change the the interface signuter
{code:java}
void hset(String key, String hashField, String value);
void set(String key, String value);
//to this
void hset(String key, String hashField, String value,int expire);
void set(String key, String value,int expire);
{code}
--
This message was sent by Atlassian JIRA
(v6.4.14#64029)
