我们还有一种更简单直接的方式,就是新建一个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) 测试类 (编辑:惠州站长网)
【声明】本站内容均来自网络,其相关言论仅代表作者个人观点,不代表本站立场。若无意侵犯到您的权利,请及时与联系站长删除相关内容!
|