Hive 的collect_set使用详解

Posted wingler

tags:

篇首语:本文由小常识网(cha138.com)小编为大家整理,主要介绍了Hive 的collect_set使用详解相关的知识,希望对你有一定的参考价值。

Hive 的collect_set使用详解

  select a,collect_set(b) as bb from t where b<=‘xxxxxx‘ group by a

会按照a分组 通过collect_set会把每个a所对应的b构建成一个以逗号分隔的数组返回。上述SQL返回:

a1,["b1","b2"]

a2,["b1","b2","b3","b4"] 

 可以按照这个返回的数组做文章,即为

select * from (select a,collect_set(b) as bb from t where b<=‘xxxxxx‘ group by a)  where size(tmp.bb)=1 and tmp.bb[0]=‘xxxxxxxx‘;

表示某bb所对应的数组长度为1 并且第一个bb为xxxxxxxx的a

以上是关于Hive 的collect_set使用详解的主要内容,如果未能解决你的问题,请参考以下文章

ElasticSearch学习问题记录——Invalid shift value in prefixCoded bytes (is encoded value really an INT?)(代码片段

项目实战——参数配置化Spark将Hive表的数据写入需要用户名密码认证的ElasticSearch(Java版本)

项目实战——参数配置化Spark将Hive表的数据写入需要用户名密码认证的ElasticSearch(Java版本)

是否可以在 ElasticSearch 中使用 presto 或 Hive (ElasticSearch-Hadoop) 的任何 ES 连接器进行 JOIN 操作?

Flink SQL 1.11新功能详解:Hive 数仓实时化 & Flink SQL + CDC 实践

解决Hive与Elasticsearch共有库 guava 冲突 NoSuchMethodError