Hive-ES配置实例

配置过程如下:

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条数据。

本文参与腾讯云自媒体分享计划,欢迎正在阅读的你也加入,一起分享。

发表于

我来说两句

0 条评论
登录 后参与评论

扫码关注云+社区

领取腾讯云代金券