20年4月27日，05:51，王双利 写道：
> >
> > 没找到 filter这个语法
> >
> >
> >
> > 王双利
> >
> > 发件人： Jark Wu
> > 发送时间： 2020-04-26 23:50
> > 收件人： user-zh
> > 主题： Re: sql 行转列
> > Hi
> >
> > 如果我理解的没错，agg with filter 语法能满足你的需求。
> >
&
n.html
<https://ci.apache.org/projects/flink/flink-docs-master/zh/dev/table/tuning/streaming_aggregation_optimization.html>
> 在 2020年4月27日，05:51，王双利 写道：
>
> 没找到 filter这个语法
>
>
>
> 王双利
>
> 发件人： Jark Wu
> 发送时间： 2020-04-26 23:50
> 收件人： user-zh
> 主题： Re: sql
没找到 filter这个语法
王双利
发件人： Jark Wu
发送时间： 2020-04-26 23:50
收件人： user-zh
主题： Re: sql 行转列
Hi
如果我理解的没错，agg with filter 语法能满足你的需求。
select ip,
sum(t) filter (where status = 'success')
sum(t) filter (where status = 'fail')
from view1
group by ip
Best,
Jark
On Sun, 26 Apr 2020 at 20:56
这个执行的结果是 successct，failct总有一个是0，两个不能共存
王双利
发件人： Benchao Li
发送时间： 2020-04-26 20:30
收件人： user-zh
主题： Re: sql 行转列
现在看起来你最开始发的SQL就可以做到你说的这个需求呀。
王双利 于2020年4月26日周日 下午6:47写道：
> 原始存的是ip status 次数，status是成功或者失败，想达到的是统计一个ip的成功和失败次数，在一行里面显示
>
>
> | |
> 王双利
> |
>
Hi
如果我理解的没错，agg with filter 语法能满足你的需求。
select ip,
sum(t) filter (where status = 'success')
sum(t) filter (where status = 'fail')
from view1
group by ip
Best,
Jark
On Sun, 26 Apr 2020 at 20:56, Leonard Xu wrote:
> Hi，
>
> > select ip,
> > case status when 'success' THEN sum(t) ELSE 0 end
子吗？
>
> 发件人： 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/que
s/flink/flink-docs-master/dev/table/functions/udfs.html#table-aggregation-functions
>
> 王双利 于2020年4月26日周日 下午6:14写道：
>
> >看到的例子，都是 对单行数据进行转行的，这种多行数据的，有相关例子吗？
> >
> > 发件人： Benchao Li
> > 发送时间： 2020-04-26 17:31
> > 收件人： user-zh
> > 主题： Re: sql 行转列
>
> 发件人： 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.
看到的例子，都是 对单行数据进行转行的，这种多行数据的，有相关例子吗？
发件人： 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
王双利
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
王双利 于2020年4月26日周日 下午5:19写道：
> select ip,
> case status when 'success' THEN sum(t) ELSE 0 end successct,
> case
10 matches
Mail list logo
