Return-Path: X-Original-To: archive-asf-public-internal@cust-asf2.ponee.io Delivered-To: archive-asf-public-internal@cust-asf2.ponee.io Received: from cust-asf.ponee.io (cust-asf.ponee.io [163.172.22.183]) by cust-asf2.ponee.io (Postfix) with ESMTP id 4C557200BA0 for ; Fri, 14 Oct 2016 14:08:22 +0200 (CEST) Received: by cust-asf.ponee.io (Postfix) id 4AEBF160ADD; Fri, 14 Oct 2016 12:08:22 +0000 (UTC) Delivered-To: archive-asf-public@cust-asf.ponee.io Received: from mail.apache.org (hermes.apache.org [140.211.11.3]) by cust-asf.ponee.io (Postfix) with SMTP id B900A160AD9 for ; Fri, 14 Oct 2016 14:08:21 +0200 (CEST) Received: (qmail 43941 invoked by uid 500); 14 Oct 2016 12:08:21 -0000 Mailing-List: contact issues-help@flink.apache.org; run by ezmlm Precedence: bulk List-Help: List-Unsubscribe: List-Post: List-Id: Reply-To: dev@flink.apache.org Delivered-To: mailing list issues@flink.apache.org Received: (qmail 43927 invoked by uid 99); 14 Oct 2016 12:08:20 -0000 Received: from arcas.apache.org (HELO arcas) (140.211.11.28) by apache.org (qpsmtpd/0.29) with ESMTP; Fri, 14 Oct 2016 12:08:20 +0000 Received: from arcas.apache.org (localhost [127.0.0.1]) by arcas (Postfix) with ESMTP id CE21B2C0059 for ; Fri, 14 Oct 2016 12:08:20 +0000 (UTC) Date: Fri, 14 Oct 2016 12:08:20 +0000 (UTC) From: "ASF GitHub Bot (JIRA)" To: issues@flink.apache.org Message-ID: In-Reply-To: References: Subject: [jira] [Commented] (FLINK-4497) Add support for Scala tuples and case classes to Cassandra sink MIME-Version: 1.0 Content-Type: text/plain; charset=utf-8 Content-Transfer-Encoding: 7bit X-JIRA-FingerPrint: 30527f35849b9dde25b450d4833f0394 archived-at: Fri, 14 Oct 2016 12:08:22 -0000 [ 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: https://github.com/apache/flink/pull/2633 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 (v6.3.4#6332)