Robert Metzger created FLINK-3311:
-------------------------------------
Summary: 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)
