[BAHIR-155] Add expire to redis sink

• Type: Wish
• Status: Resolved
• Priority: Major
• Resolution: Fixed
• Affects Version/s: Flink-1.0
• Fix Version/s: Flink-1.1.0
• Component/s: Flink Streaming Connectors
• Labels: features
• Assignee: Unassigned
• Reporter: miki haiat
• Created: 25/Dec/17 14:21
• Updated: 16/Aug/21 20:16
• Resolved: 11/Oct/19 14:52

Description

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

Issue Links

• links to: GitHub Pull Request #66