[jira] (FLINK-5683) Fix RedisConnector documentation (Java)

[Vikram Rawat (JIRA)]

Title: Message Title

Vikram Rawat updated an issue   Flink / FLINK-5683 Fix RedisConnector documentation (Java) Change By: Vikram Rawat Affects Version/s: 1.1.0 Affects Version/s: 1.1.3 Affects Version/s: 1.1.4 Labels: redis Component/s: Cassandra Connector Component/s: Streaming Connectors Summary: CLONE - Better Cassandra sink Fix RedisConnector  documentation  (Java) The  Cassandra sink  RedisConnector  documentation  is somewhat muddled and could  for Java can  be improved.   For instance, the fact that is only supports tuples and POJO's that use DataStax Mapper annotations is only mentioned in passing, and it is not clear that the reference to tuples only applies to Flink Java tuples and not Scala tuples.   The documentation also does not mention that setQuery() is only necessary for tuple streams https://ci . apache.org/projects/flink/flink-docs-release-1.1/apis/streaming/connectors/redis.html   The  explanation of  code snippet on  the  write ahead log could use some cleaning up to clarify when it  site  is  appropriate to use, ideally with an example : DataStream<String> stream = .   Maybe this would be best as a blog post to expand on the type of non-deterministic streams this applies to . .; stream.addSink(new RedisSink<Tuple2<String, String>>(conf, new RedisExampleMapper()); This gives compile time error in IDE. It  would also  should  be  useful  changed  to  mention that tuple elements will be mapped to Cassandra columns using the Datastax Java driver's default encoders : DataStream<Tuple2<String ,  which are somewhat limited (e  String>> stream = . g .  to write to a blob column .; stream.addSink(new RedisSink<Tuple2<String, String>>(conf, new RedisExampleMapper()); The code snippets on  the  type in the tuple  Project WebSite  must be  a java  accurate so I recommend this change . nio.ByteBuffer and not just  And it will only take  a  byte[])  few minutes .   Add Comment   This message was sent by Atlassian JIRA (v6.3.15#6346-sha1:dbc023d)