flink-dev mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From "Robert Metzger (JIRA)" <j...@apache.org>
Subject [jira] [Created] (FLINK-3311) Add a connector for streaming data into Cassandra
Date Mon, 01 Feb 2016 19:56:40 GMT
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)

Mime
View raw message