流批一体计算引擎-17-[Flink]中的Table API常用算子
Table API是批处理和流处理的统一的关系型API。
Table API的查询不需要修改代码就可以采用批输入或流输入来运行。
Table API是SQL语言的超集，并且是针对Apache Flink专门设计的。
Table API集成了Scala，Java和Python语言的API。
Table API的查询是使用Java，Scala或Python语言嵌入的风格定义的，有诸如自动补全和语法校验的IDE支持，而不是像普通SQL一样使用字符串类型的值来指定查询。
1 概述&示例
Table API支持Scala, Java和Python语言。
Scala语言的Table API利用了Scala表达式；
Java语言的Table API支持DSL表达式和解析并转换为等价表达式的字符串；Python语言的Table API仅支持解析并转换为等价表达式的字符串。
下面的例子展示了 Scala、Java 和 Python 语言的 Table API 的不同之处。表程序是在批环境下执行的。程序扫描了 Orders 表，通过字段 a 进行分组，并计算了每组结果的行数。
1.1 data.csv
lily,20,30,"2原文地址：https://blog.csdn.net/qq_20466211/article/details/128881306
免责声明：本站文章内容转载自网络资源，如本站内容侵犯了原著者的合法权益，可联系本站删除。更多内容请关注自学内容网（zxcms.com）！