Flink实例（114）：自定义时间和窗口的操作符（十三）自定义窗口分配器之设定窗口开始与结束时刻

本文主要是介绍Flink实例（114）：自定义时间和窗口的操作符（十三）自定义窗口分配器之设定窗口开始与结束时刻，希望对大家解决编程问题提供一定的参考价值，需要的开发者们随着小编来一起学习吧！

1. 自定义窗口分配器（flink1.11.2）

package com.atguigu.exercise.ETL.caiutilimport java.text.SimpleDateFormat
import java.util
import java.util.{Collections, Date}import org.apache.flink.api.common.ExecutionConfig
import org.apache.flink.api.common.typeutils.TypeSerializer
import org.apache.flink.streaming.api.environment.StreamExecutionEnvironment
import org.apache.flink.streaming.api.windowing.assigners.WindowAssigner
import org.apache.flink.streaming.api.windowing.triggers.{EventTimeTrigger, Trigger}
import org.apache.flink.streaming.api.windowing.windows.TimeWindowclass CustomWindowAssigner[T] extends WindowAssigner[T, TimeWindow]{overri

这篇关于Flink实例（114）：自定义时间和窗口的操作符（十三）自定义窗口分配器之设定窗口开始与结束时刻的文章就介绍到这儿，希望我们推荐的文章对编程师们有所帮助！

---