GetHBase 2.3.0.4.10.0.0-147

Bundle
org.apache.nifi | nifi-hbase-nar
Description
This Processor polls HBase for any records in the specified table. The processor keeps track of the timestamp of the cells that it receives, so that as new records are pushed to HBase, they will automatically be pulled. Each record is output in JSON format, as {"row": "<row key>", "cells": { "<column 1 family>:<column 1 qualifier>": "<cell 1 value>", "<column 2 family>:<column 2 qualifier>": "<cell 2 value>", ... }}. For each record received, a Provenance RECEIVE event is emitted with the format hbase://<table name>/<row key>, where <row key> is the UTF-8 encoded value of the row's key.
Tags
get, hbase, ingest
Input Requirement
FORBIDDEN
Supports Sensitive Dynamic Properties
false
Properties
State Management
Scopes Description
CLUSTER After performing a fetching from HBase, stores a timestamp of the last-modified cell that was found. In addition, it stores the ID of the row(s) and the value of each cell that has that timestamp as its modification date. This is stored across the cluster and allows the next fetch to avoid duplicating data, even if this Processor is run on Primary Node only and the Primary Node changes.
Relationships
Name Description
success All FlowFiles are routed to this relationship
Writes Attributes
Name Description
hbase.table The name of the HBase table that the data was pulled from
mime.type Set to application/json to indicate that output is JSON