Uploaded image for project: 'Beam'
  1. Beam
  2. BEAM-8408

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

Details

    • New Feature
    • Status: Open
    • P3
    • Resolution: Unresolved
    • 2.14.0, 2.15.0, 2.16.0
    • None
    • io-java-redis
    • None

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

      Attachments

        Activity

          People

            Unassigned Unassigned
            asokolov Andrey Sokolov
            Votes:
            0 Vote for this issue
            Watchers:
            5 Start watching this issue

            Dates

              Created:
              Updated: