[jira] [Comment Edited] (FLINK-3311) Add a connector for streaming data into Cassandra

["Andrea Sella (JIRA)" <ji...@apache.org>]

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

Andrea Sella edited comment on FLINK-3311 at 2/3/16 4:40 PM:
-------------------------------------------------------------

Yes, I can share it. 
How kind of interface I need to implement to make cassandra sink "exactly once"? 

Source: https://github.com/radicalbit/flink/tree/cassandra-connector
EDIT: source github


was (Author: alkagin):
Yes, I can share it. 
How kind of interface I need to implement to make cassandra sink "exactly once"? 

> Add a connector for streaming data into Cassandra
> -------------------------------------------------
>
>                 Key: FLINK-3311
>                 URL: https://issues.apache.org/jira/browse/FLINK-3311
>             Project: Flink
>          Issue Type: New Feature
>          Components: Streaming Connectors
>            Reporter: Robert Metzger
>            Assignee: Chesnay Schepler
>
> We had users in the past asking for a Flink+Cassandra integration.
> It seems that there is a well-developed java client for connecting into Cassandra: https://github.com/datastax/java-driver (ASL 2.0)
> There are also tutorials out there on how to start a local cassandra instance (for the tests): http://prettyprint.me/prettyprint.me/2010/02/14/running-cassandra-as-an-embedded-service/index.html
> For the data types, I think we should support TupleX types, and map standard java types to the respective cassandra types.
> In addition, it seems that there is a object mapper from datastax to store POJOs in Cassandra (there are annotations for defining the primary key and types)



--
This message was sent by Atlassian JIRA
(v6.3.4#6332)