[FLINK-3311] Add a connector for streaming data into Cassandra

• Type: New Feature
• Status: Resolved
• Priority: Major
• Resolution: Fixed
• Fix Version/s: 1.1.0
• Component/s: Connectors / Common
• Assignee: Andrea Sella
• Reporter: Robert Metzger
• Created: 01/Feb/16 19:56
• Updated: 02/Oct/19 17:50
• Resolved: 16/Jun/16 14:59

Description

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)

Issue Links

• relates to: FLINK-3332 Provide an exactly-once Cassandra connector
• links to: GitHub Pull Request #1771