public abstract class StatusEmitterBolt
extends org.apache.storm.topology.base.BaseRichBolt
Modifier and Type | Field and Description |
---|---|
protected org.apache.storm.task.OutputCollector |
collector |
Constructor and Description |
---|
StatusEmitterBolt() |
Modifier and Type | Method and Description |
---|---|
protected boolean |
allowRedirs() |
void |
declareOutputFields(org.apache.storm.topology.OutputFieldsDeclarer declarer) |
protected void |
emitOutlink(org.apache.storm.tuple.Tuple t,
URL sURL,
String newUrl,
Metadata sourceMetadata,
String... customKeyVals)
Used for redirections or when discovering sitemap URLs.
|
protected Outlink |
filterOutlink(URL sURL,
String newUrl,
Metadata sourceMetadata,
String... customKeyVals) |
void |
prepare(Map stormConf,
org.apache.storm.task.TopologyContext context,
org.apache.storm.task.OutputCollector collector) |
public void prepare(Map stormConf, org.apache.storm.task.TopologyContext context, org.apache.storm.task.OutputCollector collector)
public void declareOutputFields(org.apache.storm.topology.OutputFieldsDeclarer declarer)
protected void emitOutlink(org.apache.storm.tuple.Tuple t, URL sURL, String newUrl, Metadata sourceMetadata, String... customKeyVals)
protected Outlink filterOutlink(URL sURL, String newUrl, Metadata sourceMetadata, String... customKeyVals)
protected boolean allowRedirs()
Copyright © 2018 DigitalPebble Ltd. All rights reserved.