Hi, I was planning to use the RedisIO write/writeStreams function in a streaming pipeline.
https://beam.apache.org/releases/javadoc/current/org/apache/beam/sdk/io/redis/RedisIO.html The pipeline would read an unbounded collection from Kinesis and update redis. It will update data for which key exists and add new key/value where it does not exist. Please let me know if this IO is suitable for this purpose. I was reading up on this IO here https://beam.apache.org/documentation/io/connectors/ and it states that it only supports batch and not streaming. If this works then what is a better option to use write or writeStreams function ? Thanks Sachin
