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