We are actively evolving this toolkit. Operator names and functionality may change.
In addition to the functionality provided by the toolkit on StreamsDev:
- provided a way to HBASEPut, HBASEGet, HBASEScan to put and get an entire tuple, interpreting attribute names as column qualifiers.
- Added support for a parallelized HBASEScan
- Added an initDelay parameter to HBASEScan
Original functionality from StreamsDev:
- HBASEPut: Put a tuple into HBASE, with support for checkAndPut
- HBASEDelete: Remove a entry or an entire row from HBASE, with support for checkAndDelete
- HBASEIncrement: Increment a value
- HBASEScan: Scan a table.
- HBASEGet: Get a particular entry, or the map of column qualifiers to values, or the entire row (map of families to map of column qualifiers to values"