运行应用
CQL程序可以在Eclipse中直接提交,也可以在Linux下通过CQL命令行客户端进行提交。
应用开发客户端提交流程
在Eclipse中打开CQLExample类,点击右键选择“Run As”> “Java Application”进行任务提交。
Linux客户端提交流程
在Linux客户端CQL命令行下提交CQL语句,如图1。
图1命令行提交CQL语句

运行结果查看
登录FusionInsight Manager系统。 在浏览器地址栏中输入访问地址,地址格式为“http://FusionInsight Manager系统的WebService浮动IP地址:8080/web”。
例如,在IE浏览器地址栏中,输入“http://10.0.0.1:8080/web”。
选择“服务管理>Streaming”,点击进入Streaming WebUI,如图2。 图2Streaming服务界面

- 在Streaming WebUI中点击example应用,查看你应用程序运行情况,如图3。
图3Streaming应用程序执行界面

Topology stats统计了最近各个不同时间段的算子之间发送数据的总数据量。
Spouts中统计了spout算子从启动到现在发送的消息总量。Bolts中统计了Count算子和split算子的发送消息总量,如图4。
图4Streaming应用程序算子发送数据总量
