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 <andrea.se...@radicalbit.io>
Date: 2016-02-17T16:55:19Z
[FLINK-3311] Add a connector for streaming data into Cassandra
----
---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHub as well. If your project does not have this feature
enabled and wishes so, or if the feature is enabled but not working, please
contact infrastructure at infrastruct...@apache.org or file a JIRA ticket
with INFRA.
---
