storm自带例子详解 (五)——PrintSampleStream
2015-06-01 10:59
453 查看
/** * Licensed to the Apache Software Foundation (ASF) under one * or more contributor license agreements. See the NOTICE file * distributed with this work for additional information * regarding copyright ownership. The ASF licenses this file * to you under the Apache License, Version 2.0 (the * "License"); you may not use this file except in compliance * with the License. You may obtain a copy of the License at * * http://www.apache.org/licenses/LICENSE-2.0 * * Unless required by applicable law or agreed to in writing, software * distributed under the License is distributed on an "AS IS" BASIS, * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. * See the License for the specific language governing permissions and * limitations under the License. */ package storm.starter; import java.util.Arrays; import backtype.storm.Config; import backtype.storm.LocalCluster; import backtype.storm.topology.TopologyBuilder; import backtype.storm.utils.Utils; import storm.starter.bolt.PrinterBolt; import storm.starter.spout.TwitterSampleSpout; /* ** 打印简单的数据流 */ public class PrintSampleStream { public static void main(String[] args) { // 一系列的字符串,字符串数组 String consumerKey = args[0]; String consumerSecret = args[1]; String accessToken = args[2]; String accessTokenSecret = args[3]; String[] arguments = args.clone(); String[] keyWords = Arrays.copyOfRange(arguments, 4, arguments.length); // 定义一个拓扑构造器 TopologyBuilder builder = new TopologyBuilder(); // 设置Spout(名为twitter)——TwitterSampleSpout类型的Spout,该Spout的数据就上上面定义的那些字符串以及字符串数组 builder.setSpout("twitter", new TwitterSampleSpout(consumerKey, consumerSecret, accessToken, accessTokenSecret, keyWords)); // 设置Bolt(名为print)——PrintBolt类型的Bolt,接收twitter(Spout)的数据 builder.setBolt("print", new PrinterBolt()) .shuffleGrouping("twitter"); Config conf = new Config(); // 创建本地集群 LocalCluster cluster = new LocalCluster(); // 提交拓扑 cluster.submitTopology("test", conf, builder.createTopology()); // 睡眠一段时间 Utils.sleep(10000); // 关闭本地集群,然后清理资源 cluster.shutdown(); } }
相关文章推荐
- SAP FI-FM-BU预算
- 电子元器件散热方法布局措施
- 蓝桥杯决赛结束。
- 针对PVS方式的VDI部署趋势杀毒优化方法
- balanced binary tree
- Socket.io的一点理解
- syslog
- 浅析Spring事务传播行为和隔离级别
- mysql 赋给用户权限 grant all privileges on
- js 控制页面跳转的5种方法
- SQL语句执行效率及分析(note)
- 【第一次CTF】密码学
- RTP打包发送H.264
- Linux【Red Hat】——sudo用户管理
- wamp配置多域名虚拟目录【转】
- jquery插件库收集网站
- HttpWebRequest内存溢出 OutOfMemoryException
- mysql client命令行选项
- DirectX龙书 错误的地方 ...
- 常用正则表达式一览