You are viewing a plain text version of this content. The canonical link for it is here.
Posted to issues@nifi.apache.org by "Bryan Bende (JIRA)" <ji...@apache.org> on 2016/12/21 17:31:58 UTC

[jira] [Commented] (NIFI-1784) Create a FetchHBase Processor

    [ 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)