[BEAM-8408] [RedisIO][java] Writing with method SADD doesn't set TTL

• Type: New Feature
• Status: Open
• Priority: P3
• Resolution: Unresolved
• Affects Version/s: 2.14.0, 2.15.0, 2.16.0
• Component/s: io-java-redis
• Assignee: Unassigned
• Reporter: Andrey Sokolov
• Created: 16/Oct/19 04:40
• Updated: 04/Jun/22 13:44

Description

https://github.com/apache/beam/blob/master/sdks/java/io/redis/src/main/java/org/apache/beam/sdk/io/redis/RedisIO.java

private void writeUsingSaddCommand(KV<String, String> record, Long expireTime) {
  String key = record.getKey();
  String value = record.getValue();

  pipeline.sadd(key, value);
}