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使用分析的主要内容，如果未能解决你的问题，请参考以下文章