首页 > 其他 > 详细

在本地运行第一个strom-starter例子

时间:2015-03-27 12:10:55      阅读:369      评论:0      收藏:0      [点我收藏+]

具体步骤如下:

 

1、在Eclipse中新建java project项目并导入jar包:

    File-> New -> Java Project ->随便取个名字-> Next -> Libraries -> add External JARs...-> 追加twitter4j和storm的jar文件(/path/to/twitter4j/lib/*.jar和/path/to/storm/lib/*.jar和/path/to/storm/storm-{version}.jar)-> Finsh

 

2、追加源文件storm-start/src/jvm/storm:
    导入example中的storm-start
    File -> Import -> General -> File System -> Next -> Browse(From directory) -> /path/to/storm-start/src/jvm/storm -> Browse(Info floder)  -> xxx -> src -> OK -> 选择“storm” 和 “Create top-level folder” -> Finish
  完成之后如图所示:
          技术分享

 

3、 追加源文件storm-start/multilang/resources(python 文件word count用)
    File -> Import -> General -> File System -> Next -> Browse(From directory) -> /path/to/storm-start/multilang/resources -> Browse(Info floder)  -> xxx -> OK -> 选择 “resources” and “Create top-level folder” -> Finish

 

以上jar包和2个源文件都追加好之后,eclipse左边显示如下图:
技术分享

 

4、 导出 JAR export
    File -> Export -> JAR -> JAR file -> 取消 “.classpath” ,“.project” 和 “<.settings” ->的勾 browse -> path/to/export/name.jar -> Finish (忽视 warnings);可能会报错说PrintSampleStream和TwitterSampleSpout这两个类找不到,将这两个类的注释取消掉即可。

         技术分享

5、执行刚才编译的文件:

   在终端执行以下命令:

  # storm jar StormStarter.jar storm.starter.ExclamationTopology  

如果出现类似下面的文字,说明运行成功!
....
11367 [Thread-25] INFO  backtype.storm.daemon.task  - Emitting: class storm.starter.ExclamationTopology$ExclamationBolt source: 2:3, stream: 1, id: {}, [golda!!!]
....

 

在本地运行第一个strom-starter例子

原文:http://www.cnblogs.com/xymqx/p/4371071.html

(0)
(0)
   
举报
评论 一句话评论(0
关于我们 - 联系我们 - 留言反馈 - 联系我们:wmxa8@hotmail.com
© 2014 bubuko.com 版权所有
打开技术之扣,分享程序人生!