Thank you Eugene & Dan, I will follow these references ! Thanks, Seshadri
On Wed, May 10, 2017 at 3:55 PM, Dan Halperin <[email protected]> wrote: > 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/b >> eam/blob/master/sdks/java/io/hadoop/jdk1.8-tests/src/test/ja >> va/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 >> > >
