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 ?)

Thanks,

B.R / Cordialement

Thomas Lamirault

Reply via email to