Alink教程(Java版)
Alink教程(Python版)
该文档涉及的组件

第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;