You are viewing a plain text version of this content. The canonical link for it is here.
Posted to issues@flink.apache.org by "Michael Fong (JIRA)" <ji...@apache.org> on 2017/09/16 14:40:00 UTC

[jira] [Comment Edited] (FLINK-4498) Better Cassandra sink documentation

    [ https://issues.apache.org/jira/browse/FLINK-4498?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16168827#comment-16168827 ] 

Michael Fong edited comment on FLINK-4498 at 9/16/17 2:39 PM:
--------------------------------------------------------------

I plan to separate the document update into several tasks. 


was (Author: mcfongtw):
I would like to help updating the documents for Cassandra connector and provide more concrete (and meaningful) examples. 

> Better Cassandra sink documentation
> -----------------------------------
>
>                 Key: FLINK-4498
>                 URL: https://issues.apache.org/jira/browse/FLINK-4498
>             Project: Flink
>          Issue Type: Improvement
>          Components: Cassandra Connector, Documentation
>    Affects Versions: 1.1.0
>            Reporter: Elias Levy
>            Assignee: Michael Fong
>
> The Cassandra sink documentation is somewhat muddled and could 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. 
> The explanation of the write ahead log could use some cleaning up to clarify when it is appropriate to use, ideally with an example.  Maybe this would be best as a blog post to expand on the type of non-deterministic streams this applies to.
> It would also be useful to mention that tuple elements will be mapped to Cassandra columns using the Datastax Java driver's default encoders, which are somewhat limited (e.g. to write to a blob column the type in the tuple must be a java.nio.ByteBuffer and not just a byte[]).



--
This message was sent by Atlassian JIRA
(v6.4.14#64029)