You are viewing a plain text version of this content. The canonical link for it is here.
Posted to user@flink.apache.org by Fabian Hueske <fh...@gmail.com> on 2016/10/04 07:49:37 UTC

Re: Using Flink and Cassandra with Scala

FYI: FLINK-4497 [1] requests Scala tuple and case class support for the
Cassandra sink and was opened about a month ago.

[1] https://issues.apache.org/jira/browse/FLINK-4497

2016-09-30 23:14 GMT+02:00 Stephan Ewen <se...@apache.org>:

> How hard would it be to add case class support?
>
> Internally, tuples and case classes are treated quite similar, so I think
> it could be a quite simple extension...
>
> On Fri, Sep 30, 2016 at 4:22 PM, Sanne de Roever <
> sanne.de.roever@gmail.com> wrote:
>
>> Thanks Chesnay. Have a good weekend.
>>
>> On Thu, Sep 29, 2016 at 5:03 PM, Chesnay Schepler <ch...@apache.org>
>> wrote:
>>
>>> the cassandra sink only supports java tuples and POJO's.
>>>
>>>
>>> On 29.09.2016 16:33, Sanne de Roever wrote:
>>>
>>>> Hi,
>>>>
>>>> Does the Cassandra sink support Scala and case classes? It looks like
>>>> using Java is at the moment best practice.
>>>>
>>>> Cheers,
>>>>
>>>> Sanne
>>>>
>>>
>>>
>>
>