MAPREDUCE服务 MRS-创建Storm Bolt:代码样例
时间：2025-05-27 16:38:07
下载MAPREDUCE服务 MRS用户手册完整版
复制链接到剪贴板
分享文章到微博
分享文章到朋友圈
代码样例
下面代码片段在com.huawei.storm.example.common包的“SplitSentenceBolt”类的“execute”方法中，作用在于拆分每条语句为单个单词并发送。
/**
* {@inheritDoc}
*/
@Override
public void execute(Tuple input, BasicOutputCollector collector)
{
String sentence = input.getString(0);
String[] words = sentence.split(" ");
for (String word : words)
{
word = word.trim();
if (!word.isEmpty())
{
word = word.toLowerCase();
collector.emit(new Values(word));
}
}
}
下面代码片段在com.huawei.storm.example.wordcount.WordCountBolt类中，作用在于统计收到的每个单词的数量。
@Override
public void execute(Tuple tuple, BasicOutputCollector collector)
{
String word = tuple.getString(0);
Integer count = counts.get(word);
if (count == null)
{
count = 0;
}
count++;
counts.put(word, count);
System.out.println("word: " + word + ", count: " + count);
}support.huaweicloud.com/devg3-mrs/mrs_07_420014.html
