org.apache.storm.hbase.bolt
Class AbstractHBaseBolt
java.lang.Object
backtype.storm.topology.base.BaseComponent
backtype.storm.topology.base.BaseRichBolt
org.apache.storm.hbase.bolt.AbstractHBaseBolt
- All Implemented Interfaces:
- IBolt, IComponent, IRichBolt, Serializable
- Direct Known Subclasses:
- HBaseBolt, HBaseLookupBolt
public abstract class AbstractHBaseBolt
- extends BaseRichBolt
- See Also:
- Serialized Form
Methods inherited from class java.lang.Object |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
Methods inherited from interface backtype.storm.task.IBolt |
execute |
collector
protected OutputCollector collector
hBaseClient
protected transient HBaseClient hBaseClient
tableName
protected String tableName
mapper
protected HBaseMapper mapper
configKey
protected String configKey
AbstractHBaseBolt
public AbstractHBaseBolt(String tableName,
HBaseMapper mapper)
prepare
public void prepare(Map map,
TopologyContext topologyContext,
OutputCollector collector)
Copyright © 2015 The Apache Software Foundation. All Rights Reserved.