第5章 支持Flink SQL

答疑

1、合并数据表的操作

【问题】

问下alink有像pandas那样的合并两个表操作吗？

【答复】

有，Alink 提供了两个组件 UnionAllBatchOp 和 UnionAllStreamOp，它们是分别 针对批式数据和流式数据设计的。简介如下，更多内容参见教程5.2.3节。

2、数据文件u.user和u.item找不到

【问题】

数据文件u.user和u.item找不到？

【答复】

使用下面代码，下载数据：

http://alinklab.cn/tutorial/book_java_00_download_some_data.html

在 movielens/ml-100k/ 文件夹下

3、Flink1.9 切换到 Flink1.13 时报错

【问题】

第五章只能用Flink1.9，

import org.apache.flink.table.api.java.BatchTableEnvironment;

import org.apache.flink.table.api.java.StreamTableEnvironment;

这2个类在Flink1.9，在Flink1.13没有

【答复】

需要调整导入的jar包，如下代码所示：

//import org.apache.flink.table.api.java.BatchTableEnvironment;
//import org.apache.flink.table.api.java.StreamTableEnvironment;
import org.apache.flink.table.api.bridge.java.BatchTableEnvironment;
import org.apache.flink.table.api.bridge.java.StreamTableEnvironment;