flink-user-zh mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From 王双利 <all...@163.com>
Subject Re: Re: sql 行转列
Date Sun, 26 Apr 2020 10:14:14 GMT
   看到的例子,都是 对单行数据进行转行的,这种多行数据的,有相关例子吗?
 
发件人: Benchao Li
发送时间: 2020-04-26 17:31
收件人: user-zh
主题: Re: sql 行转列
Hi 双利,
 
在Flink里面行转列用的是Table Function,你可以参考下[1] 里面的 ”Join with
Table Function
(UDTF)“ 部分。
 
[1]
https://ci.apache.org/projects/flink/flink-docs-master/dev/table/sql/queries.html#joins
 
王双利 <allon2@163.com> 于2020年4月26日周日 下午5:19写道:
 
> select ip,
> case status when 'success' THEN sum(t) ELSE 0 end successct,
> case status when 'fail' THEN sum(t) ELSE 0 end failct
> from view1
> group by ip 这样不能行转列,有解决方案吗?
>
>
>
 
-- 
 
Benchao Li
School of Electronics Engineering and Computer Science, Peking University
Tel:+86-15650713730
Email: libenchao@gmail.com; libenchao@pku.edu.cn
Mime
  • Unnamed multipart/alternative (inline, None, 0 bytes)
View raw message