You are viewing a plain text version of this content. The canonical link for it is here.

Posted to issues@beam.apache.org by "N. M. (Jira)" <ji...@apache.org> on 2021/11/01 16:33:00 UTC

[jira] [Created] (BEAM-13159) Support for Redis 5.0 streams (XADD/XREAD/XRANGE) in RedisIO

N. M. created BEAM-13159:
----------------------------

             Summary: Support for Redis 5.0 streams (XADD/XREAD/XRANGE) in RedisIO
                 Key: BEAM-13159
                 URL: https://issues.apache.org/jira/browse/BEAM-13159
             Project: Beam
          Issue Type: New Feature
          Components: io-java-redis
    Affects Versions: 2.33.0
            Reporter: N. M.


Redis 5.0 and later support an append-only log data structure called a "stream" -- each element has a unique incrementing ID and contains one or more string:string key-value pairs.

This seems like a gimme for a stream processing platform to support, and in fact Jedis already has support for XADD/XREAD/XRANGE in it, but the current redisIO Read and Write classes only support pcollections of single KVs and thus will need some additional work to support streams.



--
This message was sent by Atlassian Jira
(v8.3.4#803005)