95-910-146-源码-FlinkSQL-Flink SQL中TableFunction使用分析

喜欢ヅ旅行 2022-09-10 11:09 107阅读 0赞

# 1.美图 #

![在这里插入图片描述][watermark_type_ZHJvaWRzYW5zZmFsbGJhY2s_shadow_50_text_Q1NETiBA5Lmd5biI5YWE_size_20_color_FFFFFF_t_70_g_se_x_16]

# 2.基本使用 #

表函数TableFunction相对标量函数ScalarFunction一对一，它是一个一对多的情况，通常使用TableFunction来完成列转行的一个操作。先通过一个实际案例了解其用法：终端设备上报数据，数据类型包含温度、耗电量等，上报方式是以多条方式上报，例如：

<table> 
 <thead> 
  <tr> 
   <th>Devid</th> 
   <th>Time</th> 
   <th>Data</th> 
  </tr> 
 </thead> 
 <tbody> 
  <tr> 
   <td>Dev01</td> 
   <td>151325534643</td> 
   <td>[{“type”:“timperature”,“value”:“10”},{“type”:“battery”,“value”:“10”}]</td> 
  </tr> 
 </tbody> 
</table>

现在希望得到如下数据格式：

<table> 
 <thead> 
  <tr> 
   <th>Devid</th> 
   <th>Time</th> 
   <th>type</th> 
   <th>value</th> 
  </tr> 
 </thead> 
 <tbody> 
  <tr> 
   <td>Dev01</td> 
   <td>151325534643</td> 
   <td>timperature</td> 
   <td>10</td> 
  </tr> 
  <tr> 
   <td>Dev01</td> 
   <td>151325534643</td> 
   <td>battery</td> 
   <td>10</td> 
  </tr> 
 </tbody> 
</table>

[watermark_type_ZHJvaWRzYW5zZmFsbGJhY2s_shadow_50_text_Q1NETiBA5Lmd5biI5YWE_size_20_color_FFFFFF_t_70_g_se_x_16]: /images/20220829/83eed95dbad84d1da6e28bc411ccb24d.png

发表评论取消回复

表情：

评论列表（有 0 条评论，107人围观）

还没有评论，来说两句吧...

相关阅读

相关（源码分析）HashSet源码分析

目录 * * 成员变量 * 构造方法 * * HashSet()：无参构造 * HashSet(int ini...

ゞ浴缸里的玫瑰/ 2024年04月17日 18:51/ 0 赞/ 143 阅读

相关（源码分析）StringBuilder源码分析

目录 * * 成员变量 * 构造方法 * * StringBuilder()：无参构造 * StringBui...

川长思鸟来/ 2024年04月17日 18:39/ 0 赞/ 121 阅读

相关（源码分析）StringBuffer源码分析

目录 * * 成员变量 * 构造方法 * * StringBuffer()：无参构造 * StringBuff...

小鱼儿/ 2024年04月17日 18:29/ 0 赞/ 138 阅读

相关 spark sql 源码分析

入口 SQLContext // 用spark执行sql,返回一个DataFrame最为结果 def sql(sqlText: String):

墨蓝/ 2023年06月18日 11:53/ 0 赞/ 30 阅读

相关 MyBatis源码分析（05）执行查询SQL

前面的获取对象的过程基本都debug完了，下面看最后一行： > String name = mapper.selectNameById(1); 也就是执行SQL语句的具体过

一时失言乱红尘/ 2022年12月09日 05:30/ 0 赞/ 155 阅读

相关 Spring源码分析使用

Aop源码分析使用 @EnableAspectJAutoProxy 抽空再写下一章 @EnableAspectJAutoPro

太过爱你忘了你带给我的痛/ 2022年12月04日 08:58/ 0 赞/ 199 阅读

相关 Hibernate格式化SQL源码分析

> Spring Boot 中使用 H2 数据库：[https://blog.csdn.net/qq\_40794973/article/details/106354143][

ゞ浴缸里的玫瑰/ 2022年11月11日 13:29/ 0 赞/ 193 阅读

相关源码分析：ThreadLocal的使用以及源码分析

最近项目中用到了ThreadLocal，一直对它的使用原理有疑惑，比如：到底是怎么实现线程间隔离、各个名词之间是什么关系？今天看了看源码，在这里总结一下，分为三个大部分去记录，

不念不忘少年蓝@/ 2022年10月03日 00:40/ 0 赞/ 351 阅读

相关 95-910-146-源码-FlinkSQL-Flink SQL中TableFunction使用分析

1.美图 ![在这里插入图片描述][watermark_type_ZHJvaWRzYW5zZmFsbGJhY2s_shadow_50_text_Q1NETiBA5Lmd5

喜欢ヅ旅行/ 2022年09月10日 11:09/ 0 赞/ 108 阅读

相关源码分析：Guava Cache的使用以及源码分析-Builder

Guava Cache是性能非常高的本地缓存，其他的还有ehcache等。相对于本地缓存还有分布式缓存，其实就是独立于业务的第三方应用，比如redis、memcahe或者自己弄

快来打我*/ 2022年01月05日 06:13/ 0 赞/ 303 阅读