Twitter Storm常见模式

根据不同的应用，你所需要的流连接类型也不同。一些应用在一段时间内连接两个流的所有元组，而另一些应用期望每个流连接基于一个不同的连接字段。其它应用的流连接可能完全不同。所有流连接类型中的常见模式是用同样的方式分割各种各样的输入流。在storm中，这是很容易做到的，只需对多个输入流基于相同字段使用字段分组，然后将多个输入流连接到一个bolt。例如： 

         
 
 

          
  
  
builder.setBolt("join", new MyJoiner(), parallelism) 
          
  
  
  .fieldsGrouping("1", new Fields("joinfield1", "joinfield2")) 
          
  
  
  .fieldsGrouping("2", new Fields("joinfield1", "joinfield2")) 
          
  
  
  .fieldsGrouping("3", new Fields("joinfield1", "joinfield2")); 
         
 
 

         
 
 

          
  
  
builder.setBolt("expand", new ExpandUrl(), parallelism) 
          
  
  
  .shuffleGrouping(1); 
         
 
 

         
 
 

          
  
  
builder.setBolt("expand", new ExpandUrl(), parallelism) 
          
  
  
  .fieldsGrouping("urls", new Fields("url")); 
         
 
 

          
  
  

           
   
   
builder.setBolt("rank", new RankObjects(), parallellism) 
           
   
   
  .fieldsGrouping("objects", new Fields("value")); 
           
   
   
builder.setBolt("merge", new MergeObjects()) 
           
   
   
  .globalGrouping("rank");