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 王双利 <all...@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: libenc...@gmail.com; libenc...@pku.edu.cn
