Hi Seshadri, Note that we have a native HBaseIO -- have you tried that one? https://github.com/apache/beam/blob/master/sdks/java/io/hbase/src/main/java/org/apache/beam/sdk/io/hbase/HBaseIO.java
If that does not work for some reason... I do not believe anyone has used HBase with that connector yet. Give it a whirl and let us know when you run into issues! Thanks, Dan On Wed, May 10, 2017 at 3:43 PM, Seshadri Raghunathan <[email protected]> wrote: > Hi, > > I am looking for some sample code / reference on how to read data from > HBase using HadoopInputFormatIO for Flink runner. > > Something similar to https://github.com/apache/ > beam/blob/master/sdks/java/io/hadoop/jdk1.8-tests/src/test/ > java/org/apache/beam/sdk/io/hadoop/inputformat/integration/tests/ > HIFIOCassandraIT.java > but for HBase on Flink runner. > > Appreciate any help in this regard ! > > Thanks, > Seshadri >
