Hi Stephan,
Thanks a lot !
I will give it a look.
Cheers
On Thu, Jul 2, 2015 at 6:05 PM, Stephan Ewen se...@apache.org wrote:
Hi!
If there is a CassandraSource for Hadoop, you can also use that with the
HadoopInputFormatWrapper.
If you want to implement a Flink-specific source, extending InputFormat is
the right thing to do. A user has started to implement a cassandra sink in
this fork (may be able to reuse some code or testing infrastructure):
https://github.com/rzvoncek/flink/tree/zvo/cassandraSink
Greetings,
Stephan
On Thu, Jul 2, 2015 at 11:34 AM, tambunanw if05...@gmail.com wrote:
Hi All,
I want to if there's a custom data source available for Cassandra ?
From my observation seems that we need to implement that by extending
InputFormat. Is there any guide on how to do this robustly ?
Cheers
--
View this message in context:
http://apache-flink-user-mailing-list-archive.2336050.n4.nabble.com/Data-Source-from-Cassandra-tp1908.html
Sent from the Apache Flink User Mailing List archive. mailing list
archive at Nabble.com.
--
Welly Tambunan
Triplelands
http://weltam.wordpress.com
http://www.triplelands.com http://www.triplelands.com/blog/
