[
https://issues.apache.org/jira/browse/FLINK-3311?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15150796#comment-15150796
]
ASF GitHub Bot commented on FLINK-3311:
---------------------------------------
GitHub user alkagin opened a pull request:
https://github.com/apache/flink/pull/1660
[FLINK-3311] Add a connector for streaming data into Cassandra
[FLINK-3311](https://issues.apache.org/jira/browse/FLINK-3311): this PR
adds OutputFormat and InputFormat, just for Tuples, for batch processing and
Sink, both Pojo and Tuples, for streaming processing.
If it is interesting to add POJOs support for batch processing, I will open
another issue.
I would mind attention to the dynamic creation of the table, at the moment
it is allowed with only parallelism of 1,
[CASSANDRA-8387](https://issues.apache.org/jira/browse/CASSANDRA-8387) .
You can merge this pull request into a Git repository by running:
$ git pull https://github.com/radicalbit/flink FLINK-3311
Alternatively you can review and apply these changes as the patch at:
https://github.com/apache/flink/pull/1660.patch
To close this pull request, make a commit to your master/trunk branch
with (at least) the following in the commit message:
This closes #1660
----
commit f9ee815cd3062b986666f8e5fc75c7c6ec8e6a9f
Author: Andrea Sella <[email protected]>
Date: 2016-02-17T16:55:19Z
[FLINK-3311] Add a connector for streaming data into Cassandra
----
> 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: Andrea Sella
>
> 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)
