public abstract class AbstractHBaseBolt extends BaseRichBolt
Modifier and Type | Field and Description |
---|---|
protected OutputCollector |
collector |
protected String |
configKey |
protected HBaseClient |
hBaseClient |
protected HBaseMapper |
mapper |
protected String |
tableName |
Constructor and Description |
---|
AbstractHBaseBolt(String tableName,
HBaseMapper mapper) |
Modifier and Type | Method and Description |
---|---|
void |
prepare(Map map,
TopologyContext topologyContext,
OutputCollector collector) |
cleanup
getComponentConfiguration
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
declareOutputFields, getComponentConfiguration
protected OutputCollector collector
protected transient HBaseClient hBaseClient
protected String tableName
protected HBaseMapper mapper
protected String configKey
public AbstractHBaseBolt(String tableName, HBaseMapper mapper)
public void prepare(Map map, TopologyContext topologyContext, OutputCollector collector)
Copyright © 2016 The Apache Software Foundation. All Rights Reserved.