Does nifi (HDF 1.2) have a processor to read records from a hbase table based on a rowkey?

[#1]

Does nifi (HDF 1.2) have a processor to read records from a hbase table based on a rowkey?

[#2]

Or are you getting the row id, col fam, col qual coming from kafka, and you want to fetch a single cell?

[#3]

JSON document with key/value pairs should be fine. Just like the response from GetHbase processor. I may create a processor for now to get going.

[#4]

@Anoop Nair if you do get something working we would be happy to help you contribute it back to NiFi if you would like to, although perfectly fine to maintain it outside of NiFi as well. Let us know if we can help.

[#5]

@bbende I was thinking of extending nifi-hbase-bundle and adding a FetchHbaseProcessor using the existing capabilities in the bundle. I'm not sure if it's the right way. I'll give it a shot. Thanks for creating a JIRA request.

[#6]

@Anoop Nair adding FetchHBase to the nifi-hbase-bundle sounds like the right approach.

The HBase processors rely on a Controller Service (HBaseClientService) to interact with HBase, which hides the HBase client from the processors. There is currently a scan method in the HBaseClientService:

public void scan(final String tableName, final Collection<Column> columns, final String filterExpression, final long minTime, final ResultHandler handler)
        throws IOException {

Technically you could probably use this with a filter expression limiting to the row id you want, but it would be a lot more efficient to create a new method in that interface that takes the table, row id, and columns to return.

[#7]

@Theena R @Anoop Nair

I submitted a pull request for a FetchHBaseRow processor that may solve your use case:

https://github.com/apache/nifi/pull/1349

Keep in mind this is "use at your own risk" right now as it has not been reviewed or merged into the NiFi codebase and is subject to change at any time.

If you have any feedback, please comment on the JIRA:

https://issues.apache.org/jira/browse/NIFI-1784

[#8]

@Bryan Bende Thank you. I am able to use it to fetch based on rowkey.