public class EsSpout
extends java.lang.Object
implements org.apache.storm.topology.IRichSpout
| Constructor and Description |
|---|
EsSpout(java.lang.String target) |
EsSpout(java.lang.String target,
java.lang.String query) |
EsSpout(java.lang.String target,
java.lang.String query,
java.util.Map configuration) |
| Modifier and Type | Method and Description |
|---|---|
void |
ack(java.lang.Object msgId) |
void |
activate() |
void |
close() |
void |
deactivate() |
void |
declareOutputFields(org.apache.storm.topology.OutputFieldsDeclarer declarer) |
void |
fail(java.lang.Object msgId) |
java.util.Map<java.lang.String,java.lang.Object> |
getComponentConfiguration() |
void |
nextTuple() |
void |
open(java.util.Map conf,
org.apache.storm.task.TopologyContext context,
org.apache.storm.spout.SpoutOutputCollector collector) |
public EsSpout(java.lang.String target)
public EsSpout(java.lang.String target,
java.lang.String query)
public EsSpout(java.lang.String target,
java.lang.String query,
java.util.Map configuration)
public void open(java.util.Map conf,
org.apache.storm.task.TopologyContext context,
org.apache.storm.spout.SpoutOutputCollector collector)
open in interface org.apache.storm.spout.ISpoutpublic void close()
close in interface org.apache.storm.spout.ISpoutpublic void activate()
activate in interface org.apache.storm.spout.ISpoutpublic void deactivate()
deactivate in interface org.apache.storm.spout.ISpoutpublic void nextTuple()
nextTuple in interface org.apache.storm.spout.ISpoutpublic void ack(java.lang.Object msgId)
ack in interface org.apache.storm.spout.ISpoutpublic void fail(java.lang.Object msgId)
fail in interface org.apache.storm.spout.ISpoutpublic void declareOutputFields(org.apache.storm.topology.OutputFieldsDeclarer declarer)
declareOutputFields in interface org.apache.storm.topology.IComponentpublic java.util.Map<java.lang.String,java.lang.Object> getComponentConfiguration()
getComponentConfiguration in interface org.apache.storm.topology.IComponent