使用Storm实现实时大数据分析！_大数据_计算头条_中国计算网——工业互联网一站式服务平台—

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

{

ParallelFileSpout parallelFileSpout = new ParallelFileSpout();

ThresholdBolt thresholdBolt = new ThresholdBolt();

DBWriterBolt dbWriterBolt = new DBWriterBolt();

TopologyBuilder builder = new TopologyBuilder();

builder.setSpout("spout", parallelFileSpout, 1);

builder.setBolt("thresholdBolt", thresholdBolt,1).shuffleGrouping("spout");

builder.setBolt("dbWriterBolt",dbWriterBolt,1).shuffleGrouping("thresholdBolt");

if(this