Hive-ES配置实例

2019年6月7日 251次阅读 来源: YG_9013

配置过程如下：

1）添加jar包

    add jar file:///path/to/elasticsearch-hadoop-hive-5.2.0.jar;

2）创建一个hive-es对应表

create external table tmp.es_guo_test(
    imp_date string,
    group_code string,
    member_uin string,
    uin_flag bigint,
    ex_flag bigint,
    ower_flag bigint,
    xx_flag bigint
)STORED BY 'org.elasticsearch.hadoop.hive.EsStorageHandler'
TBLPROPERTIES('es.nodes'='xxx','es.port'='9200','es.index.auto.create'='true','es.resource'='customer/guo_test','es.nodes.wan.only'='true');
  1. 向外部表中导数据，则数据会自动写入ES中
  insert overwrite table tmp.es_guo_test select imp_date,group_code,member_uin from tmp.guo_test where dt=20170813 limit 3000;

现在，查看ES索引，自动创建了customer索引，且有3000条数据。

    原文作者：YG_9013
    原文地址: https://www.jianshu.com/p/ec767aa76400
    本文转自网络文章，转载此文章仅为分享知识，如有侵权，请联系博主进行删除。
点赞