Using Flink and Cassandra with Scala

[Sanne de Roever]

Hi,

Does the Cassandra sink support Scala and case classes? It looks like using Java is at the moment best practice.

Cheers,

Sanne

[Chesnay Schepler]

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

[Sanne de Roever]

Thanks Chesnay. Have a good weekend.

On Thu, Sep 29, 2016 at 5:03 PM, Chesnay Schepler <[hidden email]> 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

[Stephan Ewen]

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 <[hidden email]> wrote:

Thanks Chesnay. Have a good weekend.

On Thu, Sep 29, 2016 at 5:03 PM, Chesnay Schepler <[hidden email]> 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

[Fabian Hueske-2]

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 <[hidden email]>:

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 <[hidden email]> wrote:

Thanks Chesnay. Have a good weekend.

On Thu, Sep 29, 2016 at 5:03 PM, Chesnay Schepler <[hidden email]> 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