public class TweetPreprocessingBolt extends BaseTwitterRichBolt
AbstractTwitterPreprocessingToolOptions and preprocess
tweets| Constructor and Description |
|---|
TweetPreprocessingBolt(String outputQueue,
List<String> hosts,
String[] args) |
| Modifier and Type | Method and Description |
|---|---|
void |
prepare() |
void |
processTweet(String statusString) |
void |
setExpireTime(int expire) |
declareOutputFields, execute, preparepublic TweetPreprocessingBolt(String outputQueue, List<String> hosts, String[] args)
outputQueue - hosts - args - public void prepare()
prepare in class BaseTwitterRichBoltpublic void setExpireTime(int expire)
public void processTweet(String statusString) throws Exception
processTweet in class BaseTwitterRichBoltException