public class HiveBolt extends BaseRichBolt
Constructor and Description |
---|
HiveBolt(HiveOptions options) |
Modifier and Type | Method and Description |
---|---|
void |
cleanup() |
void |
declareOutputFields(OutputFieldsDeclarer declarer) |
void |
execute(Tuple tuple) |
void |
prepare(Map conf,
TopologyContext topologyContext,
OutputCollector collector) |
getComponentConfiguration
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
getComponentConfiguration
public HiveBolt(HiveOptions options)
public void prepare(Map conf, TopologyContext topologyContext, OutputCollector collector)
public void execute(Tuple tuple)
public void declareOutputFields(OutputFieldsDeclarer declarer)
public void cleanup()
cleanup
in interface IBolt
cleanup
in class BaseRichBolt
Copyright © 2016 The Apache Software Foundation. All Rights Reserved.