MAPREDUCE服务 MRS-创建Strom Spout:代码样例

时间：2024-06-29 14:11:13

MAPREDUCE服务 MRS

代码样例

下面代码片段在com.huawei.storm.example.common包的“RandomSentenceSpout”类的“nextTuple”方法中，作用在于将收到的字符串拆分成单词。

/**  
   * {@inheritDoc}  
   */  
  @Override  
  public void nextTuple()  
  {  
      Utils.sleep(100);  
      String[] sentences =  
          new String[] {"the cow jumped over the moon",   
                        "an apple a day keeps the doctor away",  
                        "four score and seven years ago",   
                        "snow white and the seven dwarfs",   
                        "i am at two with nature"};  
      String sentence = sentences[random.nextInt(sentences.length)];  
      collector.emit(new Values(sentence));  
  }

上一篇：MAPREDUCE服务 MRS-HBase应用开发流程介绍

下一篇：MAPREDUCE服务 MRS-使用Scan API读取HBase表数据:代码样例