flink的Table类型的变量两种输出的形式

是否需要env.execute()

数据处理类型

具体代码

需要

流处理

Table table = tEnv.sqlQuery("select test() as a,test(a) as b, test(a,b,c) as c from t");
DataStream<Row> res = tEnv.toAppendStream(table, Row.class);
res.print();
env.execute();

不需要

批处理

tableEnv.registerTable("tableA",tableA);
Table result2 = tableEnv.sqlQuery("SELECT content,HASHCODE(content) FROM tableA");
tableEnv.toDataSet(result2,Row.class).print();

原因是:

批的collect方法里显示调用了execute

flink的Table类型的变量两种输出的形式相关推荐

java整型转换为数组_基于java中byte数组与int类型的转换(两种方法)
java中byte数组与int类型的转换,在网络编程中这个算法是最基本的算法,我们都知道,在socket传输中,发送.者接收的数据都是 byte数组,但是int类型是4个byte组成的,如何把一个整形 ...
两种磁盘分区形式MBR(只支持4个主分区)和GPT
两种磁盘分区形式MBR(只支持4个主分区)和GPT: MBR: master boot record(主引导记录),存在于驱动器开始部分的特殊启动扇区,是存在于驱动器开始部分的一个特殊启动扇区,包括已 ...
用条件编译方法实现以下功能：输入一行电报文字，可以任选两种输出，一为原文输出；一为将字母变成其下一个字母。用define命令控制
用条件编译方法实现以下功能:输入一行电报文字,可以任选两种输出,一为原文输出:一为将字母变成其下一个字母(a变成b,-,z变成a,其他字符不变).用define命令来控制是否要译成密码. 通过宏定义中 ...
习题 4.15 用条件编译方法实现以下功能：输入一行电报文字，可以任选两种输出，一为原文输出；一为将字母变成其下一字母。用#define命令来控制是否要译成密码。
C++程序设计(第三版) 谭浩强习题4.15 个人设计习题 4.15 用条件编译方法实现以下功能:输入一行电报文字,可以任选两种输出,一为原文输出:一为将字母变成其下一字母.(如'a'变成'b'· ...
射频功率衰减器一般采用电阻元件，有两种主要电路形式：π型和T型
射频功率衰减器一般采用电阻元件,有两种主要电路形式:π型和T型. 工具下载:https://download.csdn.net/download/xingqingly/12921701 1,π型,输入 ...
matlab函数输出语句,matlab两种输出语句分别是什么
matlab两种输出语句分别是什么发布时间:2021-02-26 14:21:27 来源:亿速云阅读:79 作者:小新这篇文章主要介绍了matlab两种输出语句分别是什么,具有一定借鉴价值,感兴 ...
C++/C++11中用于定义类型别名的两种方法：typedef和using
类型别名(type alias)是一个名字,它是某种类型的同义词.使用类型别名有很多好处,它让复杂的类型名字变得简单明了.易于理解和使用,还有助于程序员清楚地知道使用该类型的真实目的.在C++中,任何 ...
Flink获取外部传递参数的两种方式
目录一.前言二.实现 2.1 通过参数方式直接传递 2.2 通过配置文件来获取参数值一.前言在Flink中,我们会对接Kafka,Kafka的参数比较多,如果我们希望通过灵活的方式修改参数,而 ...
c语言中的文件类型只有文本文件一种,C语言中的文件类型只有哪两种_后端开发...
pycharm能干嘛_后端开发 PyCharm是一种Python IDE,带有一整套可以帮助用户在使用Python语言开发时提高其效率的工具,比如调试.语法高亮.Project管理.代码跳转.智能提示 ...

flink的Table类型的变量两种输出的形式

flink的Table类型的变量两种输出的形式相关推荐

最新文章

热门文章