flink-user mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From Nick Dimiduk <ndimi...@apache.org>
Subject Re: Sink - Cassandra
Date Tue, 05 Jan 2016 15:05:42 GMT
Hi Sebastian,

I've had preliminary success with a steaming job that is Kafka -> Flink ->
HBase (actually, Phoenix) using the Hadoop OutputFormat adapter. A little
glue was required but it seems to work okay. My guess it it would be the
same for Cassandra. Maybe that can get you started?

Good luck,
-Nick

On Tuesday, January 5, 2016, Aljoscha Krettek <aljoscha@apache.org> wrote:

> Hi Sebastian,
> I’m afraid the people working on Flink don’t have much experience with
> Cassandra. Maybe you could look into the Elasticsearch sink and adapt it to
> write to Cassandra instead. That could be a valuable addition to Flink.
>
> Cheers,
> Aljoscha
> > On 22 Dec 2015, at 14:36, syepes <syepes@gmail.com <javascript:;>>
> wrote:
> >
> > Hello,
> >
> > I have just started testing out Flink and would like to migrate one of my
> > Spark Streaming jobs (Kafka->Spark->C*) to Flink.
> >
> > - Is there anyone using with Flink with Cassandra?
> > - Does there exist a working Cassandra Sink, the only thing I have found
> is:
> >
> https://github.com/rzvoncek/flink/tree/2b281120f4206c4fd66bec22090e0b6d62ebb8ad/flink-staging/flink-cassandra
> >
> > Regards,
> > Sebastian
> >
> >
> >
> >
> > --
> > View this message in context:
> http://apache-flink-user-mailing-list-archive.2336050.n4.nabble.com/Sink-Cassandra-tp4107.html
> > Sent from the Apache Flink User Mailing List archive. mailing list
> archive at Nabble.com.
>
>

Mime
View raw message