public class TweetPreprocessingBolt extends BaseTwitterRichBolt
AbstractTwitterPreprocessingToolOptions
and preprocess
tweetsConstructor 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, prepare
public TweetPreprocessingBolt(String outputQueue, List<String> hosts, String[] args)
outputQueue
- hosts
- args
- public void prepare()
prepare
in class BaseTwitterRichBolt
public void setExpireTime(int expire)
public void processTweet(String statusString) throws Exception
processTweet
in class BaseTwitterRichBolt
Exception