运行应用


CQL程序可以在Eclipse中直接提交,也可以在Linux下通过CQL命令行客户端进行提交。

应用开发客户端提交流程

在Eclipse中打开CQLExample类,点击右键选择“Run As”> “Java Application”进行任务提交。

Linux客户端提交流程

在Linux客户端CQL命令行下提交CQL语句,如图1。

图1命令行提交CQL语句

运行结果查看

  1. 登录FusionInsight Manager系统。 在浏览器地址栏中输入访问地址,地址格式为“http://FusionInsight Manager系统的WebService浮动IP地址:8080/web”。

    例如,在IE浏览器地址栏中,输入“http://10.0.0.1:8080/web”。

  2. 选择“服务管理>Streaming”,点击进入Streaming WebUI,如图2。 图2Streaming服务界面

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

Topology stats统计了最近各个不同时间段的算子之间发送数据的总数据量。

Spouts中统计了spout算子从启动到现在发送的消息总量。Bolts中统计了Count算子和split算子的发送消息总量,如图4。

图4Streaming应用程序算子发送数据总量

results matching ""

    No results matching ""