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)
