标签：多行 输出 Flink API udf table Table operation 输入

1.table api特点：

使得多声明的数据处理起来更为容易，扩展标准sql更为容易

 

enviroment：

 

 

 

如何得到一个表：

1.自己写table的描述信息

2.通过自定义tablesouce注册到env中

3.datastream也可以通过注册得到一个表

 

 

 

如何输出一个table：

和输入的三种方式是一致的

 

 

 

 

如何查询一个表：

对列上一些函数：

 

 

 

 

对列上的一些操作：

addcolumns添加，addorreplacecolumns添加并且覆盖，renamecolumns重命名，dropcolumns删除

withcolumns选择指定的列，withoutcolumns反选指定的列

cloumns使用的语法：

 

 可以是字段名，下标，默认下标是从1开始计算的

 

 

row-based operation：

map-operation的好处：

比如需要对这个表中的每一列都做一些udf的操作，比如if，cocat这种，

你就需要对每列都写一个udf，但是如果在table上使用map算子就会非常方便

 

 

flatmap-opreation：

输入一行-输出多行

 

 

aggregate-operation：

输入多行-输出一行

 

 

输入多行-输出多行：topn

flataggregate-operation:

 

 

aggregate vs tableaggregate:

 

 

 

总结：

 

标签：多行,输出,Flink,API,udf,table,Table,operation,输入
来源： https://www.cnblogs.com/javazyh/p/13046739.html

本站声明： 1. iCode9 技术分享网（下文简称本站）提供的所有内容，仅供技术学习、探讨和分享；
2. 关于本站的所有留言、评论、转载及引用，纯属内容发起人的个人观点，与本站观点和立场无关；
3. 关于本站的所有言论和文字，纯属内容发起人的个人观点，与本站观点和立场无关；
4. 本站文章均是网友提供，不完全保证技术分享内容的完整性、准确性、时效性、风险性和版权归属；如您发现该文章侵犯了您的权益，可联系我们第一时间进行删除；
5. 本站为非盈利性的个人网站，所有内容不会用来进行牟利，也不会利用任何形式的广告来间接获益，纯粹是为了广大技术爱好者提供技术内容和技术思想的分享性交流网站。