使用Storm实现实时大数据分析!

  •                          String[] fields=null;  
  •                           if (tupleInfo.getDelimiter().equals("|"))  fields = line.split("\\"+tupleInfo.getDelimiter());   
  •                           else   
  •                           fields = line.split  (tupleInfo.getDelimiter());   
  •                           if (tupleInfo.getFieldList().size() == fields.length)  _collector.emit(new Values(fields));  
  •                     }  
  •                }  
  •             }  
  •             catch (IOException ex){ }