I've added an example of HBase writing at flink-staging/flink-hbase/src/test/java/org/apache/flink/addons/hbase/example/HBaseWriteExample.java. Otherwise you can look at these 2 URLs:
- https://github.com/fpompermaier/flink/blob/hbaseOutExample/flink-staging/flink-hbase/src/test/java/org/apache/flink/addons/hbase/example/HBaseWriteExample.java - https://github.com/apache/flink/blob/57615aaa19e9933e43ed0431a78dd231bf98b103/flink-staging/flink-hbase/src/test/java/org/apache/flink/addons/hbase/example/HBaseWriteExample.java Best, Flavio On Wed, May 20, 2015 at 10:16 AM, Hilmi Yildirim <hilmi.yildi...@neofonie.de > wrote: > Hi, > I want to write a stream continuously into an HBase. For example, I have 1 > source and 4 workers. I want that each worker writes autonomously into > HBase. Is there a proper way to do it? > > Best Regards, > > -- > -- > Hilmi Yildirim > Software Developer R&D > > T: +49 30 24627-281 > hilmi.yildi...@neofonie.de > > http://www.neofonie.de > > Besuchen Sie den Neo Tech Blog für Anwender: > http://blog.neofonie.de/ > > Folgen Sie uns: > https://plus.google.com/+neofonie > http://www.linkedin.com/company/neofonie-gmbh > https://www.xing.com/companies/neofoniegmbh > > Neofonie GmbH | Robert-Koch-Platz 4 | 10115 Berlin > Handelsregister Berlin-Charlottenburg: HRB 67460 > Geschäftsführung: Thomas Kitlitschko > >