flink-issues mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From "ASF GitHub Bot (JIRA)" <j...@apache.org>
Subject [jira] [Commented] (FLINK-4497) Add support for Scala tuples and case classes to Cassandra sink
Date Fri, 14 Oct 2016 12:08:20 GMT

    [ https://issues.apache.org/jira/browse/FLINK-4497?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15575145#comment-15575145

ASF GitHub Bot commented on FLINK-4497:

Github user zentol commented on the issue:

    The important class is `CassandraScalaProductSink` which extracts the fields from the
scala classes. Apart from that it behaves exactly like the `CassandraTupleSink`. As a result
of that this common behavior was refactored into a common abstract class.
    The `CassandraSinkBuilder` was slightly refactored to fail on unsupported types and not
simply assume POJO's. In addition, the `sanityCheck()` method is now guaranteed to be called.

> 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
>            Assignee: Chesnay Schepler
> 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

View raw message