[ 
https://issues.apache.org/jira/browse/NIFI-1784?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15767625#comment-15767625
 ] 

Bryan Bende commented on NIFI-1784:
-----------------------------------

I've been working on a processor for this ticket that I am going to submit a PR 
for shortly...

I decided to limit the scope a little bit and called it FetchHBaseRow. It takes 
an incoming flow file to trigger execution, and table name, row id, and columns 
(optional) can all come from flow file attributes with EL, or can be static 
values.

The cells of the row can be added to the flow file as attributes, or the 
content of the flow file can be overridden with a JSON document (either whole 
row, or flat quals/value pairs).

I think if other use cases come up we could implement some variations like 
FetchHBaseCell to write the bytes of a cell directly to a flow file for binary 
data scenarios, or maybe a FetchHBaseRowBatch that takes an incoming flow file 
with a list of row ids to fetch. For now I think the processor I described 
above should handle the initial need.

> Create a FetchHBase Processor
> -----------------------------
>
>                 Key: NIFI-1784
>                 URL: https://issues.apache.org/jira/browse/NIFI-1784
>             Project: Apache NiFi
>          Issue Type: Improvement
>            Reporter: Bryan Bende
>            Assignee: Bryan Bende
>            Priority: Minor
>
> We should provide a processor to fetch a row from HBase. The processor should 
> support receiving an incoming FlowFile and taking the row id to fetch from an 
> attribute on the incoming, and should also be able to fetch a static row id.



--
This message was sent by Atlassian JIRA
(v6.3.4#6332)

Reply via email to