Apache Flink 漫谈系列 - SQL概览

我们还有一种更简单直接的方式，就是新建一个mvn项目，并在pom中添加如下依赖：

<properties> 
<table.version>1.6-SNAPSHOT</table.version> 
</properties> 
 
<dependencies> 
<dependency> 
<groupId>org.apache.flink</groupId> 
<artifactId>flink-table_2.11</artifactId> 
<version>${table.version}</version> 
</dependency> 
 
<dependency> 
<groupId>org.apache.flink</groupId> 
<artifactId>flink-scala_2.11</artifactId> 
<version>${table.version}</version> 
</dependency> 
 
<dependency> 
<groupId>org.apache.flink</groupId> 
<artifactId>flink-streaming-scala_2.11</artifactId> 
<version>${table.version}</version> 
</dependency> 
 
<dependency> 
<groupId>org.apache.flink</groupId> 
<artifactId>flink-streaming-java_2.11</artifactId> 
<version>${table.version}</version> 
</dependency> 
 
<dependency> 
<groupId>JUnit</groupId> 
<artifactId>JUnit</artifactId> 
<version>4.12</version> 
</dependency> 
 
</dependencies> 

完成环境准备后，我们开始准备测试数据和写一个简单的测试类。

2. 示例数据及测试类

(1) 测试数据

• customer_tab 表 - 客户表保存客户id，客户姓名和客户描述信息。字段及测试数据如下：

• order_tab 表 - 订单表保存客户购买的订单信息，包括订单id，订单时间和订单描述信息。 字段节测试数据如下：

• Item_tab商品表, 携带商品id，商品类型，出售时间，价格等信息，具体如下：

• PageAccess_tab页面访问表，包含用户ID，访问时间，用户所在地域信息，具体数据如下：

• PageAccessCount_tab页面访问表，访问量，访问时间，用户所在地域信息，具体数据如下：

• PageAccessSession_tab页面访问表，访问量，访问时间，用户所在地域信息，具体数据如下：

(2) 测试类

（编辑：惠州站长网）

【声明】本站内容均来自网络，其相关言论仅代表作者个人观点，不代表本站立场。若无意侵犯到您的权利，请及时与联系站长删除相关内容!