public class EsSpout extends java.lang.Object implements 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(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,
TopologyContext context,
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,
TopologyContext context,
SpoutOutputCollector collector)
public void deactivate()
deactivate in interface ISpoutpublic void declareOutputFields(OutputFieldsDeclarer declarer)
declareOutputFields in interface IComponentpublic java.util.Map<java.lang.String,java.lang.Object> getComponentConfiguration()
getComponentConfiguration in interface IComponent