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