Hi All,
I've been working with apache beam in the last year which I found a very
powerful tool. That said, last month I started to integrate the code with
RedisIO and I noticed that the Writing method PFADD for RedisIO does not set
the TTL.
I checked the code and seems that we are missing one line of code in:
private void writeUsingHLLCommand(KV<String, String> record, Long expireTime) {
String key = record.getKey();
String value = record.getValue();
pipeline.pfadd(key, value);
//TODO: Possibly fix for that is only adding this piece of code below
//setExpireTimeWhenRequired(key, expireTime);
}
I also logged a ticket in Jira: https://issues.apache.org/jira/browse/BEAM-13284
I was wondering if one of you guys could make that fix?
Best Regards,
