95-910-146-源码-FlinkSQL-Flink SQL中TableFunction使用分析
Posted 九师兄
tags:
篇首语:本文由小常识网(cha138.com)小编为大家整理,主要介绍了95-910-146-源码-FlinkSQL-Flink SQL中TableFunction使用分析相关的知识,希望对你有一定的参考价值。
1.美图
2.基本使用
表函数TableFunction相对标量函数ScalarFunction一对一,它是一个一对多的情况,通常使用TableFunction来完成列转行的一个操作。先通过一个实际案例了解其用法:终端设备上报数据,数据类型包含温度、耗电量等,上报方式是以多条方式上报,例如:
Devid | Time | Data |
---|---|---|
Dev01 | 151325534643 | [{“type”:“timperature”,“value”:“10”},{“type”:“battery”,“value”:“10”}] |
现在希望得到如下数据格式:
Devid | Time | type | value |
---|---|---|---|
Dev01 | 151325534643 | timperature | 10 |
Dev01 | 151325534643 | battery | 10 |
以上是关于95-910-146-源码-FlinkSQL-Flink SQL中TableFunction使用分析的主要内容,如果未能解决你的问题,请参考以下文章