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

免费分享20套微信小程序源码 源码免费下载强烈推荐

JDK源码集合源码目录,冲冲冲

android狼人杀源码,桌面源码,猎豹快切源码

Rxjava 源码解析 - 线程切换源码

Rxjava 源码解析 - 线程切换源码

Gradle获取源码sourceSets