public class HBaseLookupBolt extends AbstractHBaseBolt
collector, configKey, hBaseClient, mapper, tableName
Constructor and Description |
---|
HBaseLookupBolt(String tableName,
HBaseMapper mapper,
HBaseValueMapper rowToTupleMapper) |
Modifier and Type | Method and Description |
---|---|
void |
declareOutputFields(OutputFieldsDeclarer outputFieldsDeclarer) |
void |
execute(Tuple tuple) |
HBaseLookupBolt |
withConfigKey(String configKey) |
HBaseLookupBolt |
withProjectionCriteria(HBaseProjectionCriteria projectionCriteria) |
prepare
cleanup
getComponentConfiguration
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
getComponentConfiguration
public HBaseLookupBolt(String tableName, HBaseMapper mapper, HBaseValueMapper rowToTupleMapper)
public HBaseLookupBolt withConfigKey(String configKey)
public HBaseLookupBolt withProjectionCriteria(HBaseProjectionCriteria projectionCriteria)
public void execute(Tuple tuple)
public void declareOutputFields(OutputFieldsDeclarer outputFieldsDeclarer)
Copyright © 2016 The Apache Software Foundation. All Rights Reserved.