Flink实践代码-Watermark_flink 实战代码

1.代码与含义解释

1.1 思路

Flink 获取数据流后，需要做数据过滤那么首先就要有一下几个步骤：

1. 构建运行环境
2. 接入数据流
3. 数据加入 WaterMark

1.2 直接上代码

package com.youtree.flink;
 
import org.apache.flink.connector.datagen.table.DataGenConnectorOptions;
import org.apache.flink.table.api.*;
 
import static org.apache.flink.table.api.Expressions.$;
import static org.apache.flink.table.api.Expressions.lit;
 
/******************************************************
 * @program        : com.youtree.flink
 * @ClassName      : Visit_Info_for_watermark
 * @Author