org.apache.storm.hbase.bolt
Class HBaseLookupBolt

java.lang.Object
  extended by backtype.storm.topology.base.BaseComponent
      extended by backtype.storm.topology.base.BaseRichBolt
          extended by org.apache.storm.hbase.bolt.AbstractHBaseBolt
              extended by org.apache.storm.hbase.bolt.HBaseLookupBolt
All Implemented Interfaces:
IBolt, IComponent, IRichBolt, Serializable

public class HBaseLookupBolt
extends AbstractHBaseBolt

Basic bolt for querying from HBase. Note: Each HBaseBolt defined in a topology is tied to a specific table.

See Also:
Serialized Form

Field Summary
 
Fields inherited from class org.apache.storm.hbase.bolt.AbstractHBaseBolt
collector, configKey, hBaseClient, mapper, tableName
 
Constructor Summary
HBaseLookupBolt(String tableName, HBaseMapper mapper, HBaseValueMapper rowToTupleMapper)
           
 
Method Summary
 void declareOutputFields(OutputFieldsDeclarer outputFieldsDeclarer)
           
 void execute(Tuple tuple)
           
 HBaseLookupBolt withConfigKey(String configKey)
           
 HBaseLookupBolt withProjectionCriteria(HBaseProjectionCriteria projectionCriteria)
           
 
Methods inherited from class org.apache.storm.hbase.bolt.AbstractHBaseBolt
prepare
 
Methods inherited from class backtype.storm.topology.base.BaseRichBolt
cleanup
 
Methods inherited from class backtype.storm.topology.base.BaseComponent
getComponentConfiguration
 
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
 
Methods inherited from interface backtype.storm.topology.IComponent
getComponentConfiguration
 

Constructor Detail

HBaseLookupBolt

public HBaseLookupBolt(String tableName,
                       HBaseMapper mapper,
                       HBaseValueMapper rowToTupleMapper)
Method Detail

withConfigKey

public HBaseLookupBolt withConfigKey(String configKey)

withProjectionCriteria

public HBaseLookupBolt withProjectionCriteria(HBaseProjectionCriteria projectionCriteria)

execute

public void execute(Tuple tuple)

declareOutputFields

public void declareOutputFields(OutputFieldsDeclarer outputFieldsDeclarer)


Copyright © 2015 The Apache Software Foundation. All Rights Reserved.