《Storm实时数据处理》一2.5 索引与持久化日志数据
本节书摘来华章计算机《Storm实时数据处理》一书中的第2章 ,第2.5节,(澳)Quinton Anderson 著 卢誉声 译更多章节内容可以访问云栖社区“华章计算机”公众号查看。
2.5 索引与持久化日志数据
我们需要在某些特定时期将日志数据存储起来以便后期利用,而且还要保证这些日志数据能够被检索。为了实现这个目标,本例中将会集成名为Elastic Search的开源产品,它是一个通用并集成RESTful API的集群搜索引擎(http://www.elasticsearch.org/)。
2.5.1 实战
Step01 创建一个继承自BaseRichBolt的IndexerBolt类,并声明org.elasticsearch.client.Client 私有成员变量。你需要在prepare方法中初始化它,代码如下:
Step02 然
