Hi Thomas, You can use both of the suggested solutions.
The benefit that you might get from HBaseOutputformat that it is already tested and integrated with Flink as opposed to you having to connect to HBase in a general SinkFunction. Best, Marton On Dec 22, 2015 1:04 PM, "Thomas Lamirault" <[email protected]> wrote: > 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 >
