flink-user mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From Thomas Lamirault <thomas.lamira...@ericsson.com>
Subject Flink application with HBase
Date Tue, 22 Dec 2015 12:04:06 GMT
Hello everybody,

I am using Flink (0.10.1) with a streaming source (Kafka) , and I write results of  flatMap/keyBy/timeWindow/reduce
to a HBase table.
I have try with a class (Sinkclass) who implements SinkFunction<MyObject>, and a class
(HBaseOutputFormat) who implements OutputFormat<MyObject>. For you, it's better to use
the Sinkclass or HBaseOutputFormat, for better performance and cleaner code ? (Or equivalent


B.R / Cordialement

Thomas Lamirault

View raw message