HBase数据同步到ElasticSearch的方案
ElasticSearch的River机制
ElasticSearch自身提供了一个River机制,用于同步数据。
这里可以找到官方目前推荐的River:
http://www.elasticsearch.org/guide/en/elasticsearch/rivers/current/
但是官方没有提供HBase的River。
ElasticSearch学习笔记1-修改文档
本文中所有用[]括起来的和xxx都是变量
基本操作:1、根据id修改文档,使用POST请求
POST /[index]/[type]/[id]/_update
{
"doc": {"[XXX]":"[xxxxx]"}
}
举例:
上面这个图片中index为test,type为doc,id为1.
使用Flink实现索引数据到Elasticsearch
5万人关注的大数据成神之路,不来了解一下吗?
5万人关注的大数据成神之路,真的不来了解一下吗?
5万人关注的大数据成神之路,确定真的不来了解一下吗?
欢迎您关注《大数据成神之路》
使用Flink处理数据时,可以基于Flink提供的批式处理(Batch Processing)和流式处理(Streaming Processing)API来实现,分别能够满足不同场景下应用数据的处理。