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 

 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);

This message was sent by Atlassian JIRA

Reply via email to