[jira] [Created] (FLINK-4497) Add support for Scala tuples and case classes to Cassandra sink

classic Classic list List threaded Threaded
1 message Options
Reply | Threaded
Open this post in threaded view
|

[jira] [Created] (FLINK-4497) Add support for Scala tuples and case classes to Cassandra sink

Shang Yuanchun (Jira)
Elias Levy created FLINK-4497:
---------------------------------

             Summary: Add support for Scala tuples and case classes to Cassandra sink
                 Key: FLINK-4497
                 URL: https://issues.apache.org/jira/browse/FLINK-4497
             Project: Flink
          Issue Type: Improvement
          Components: Cassandra Connector
    Affects Versions: 1.1.0
            Reporter: Elias Levy


The new Cassandra sink only supports streams of Flink Java tuples and Java POJOs that have been annotated for use by Datastax Mapper.  The sink should be extended to support Scala types and case classes.



--
This message was sent by Atlassian JIRA
(v6.3.4#6332)