required: org.apache.flink.streaming.api.scala.function.ProcessWindowFunction[(Long, String, String

–>

Error:(48, 46) not found: type Context
override def process(key: String, context: Context, elements: Iterable[(Long, String, String)], out: Collector[String]): Unit = {
Error:(36, 16) type mismatch;
found : com.bai.MyWindowFunction
required: org.apache.flink.streaming.api.scala.function.ProcessWindowFunction[(Long, String, String),String,String,org.apache.flink.streaming.api.windowing.windows.TimeWindow]
.process(new MyWindowFunction)
Error:(47, 32) not found: type ProcessWindowFunction
class MyWindowFunction extends ProcessWindowFunction[(Long,String,String),String,String,TimeWindow] {

• 1. 包引入错误，选择下图第一个
• 2.1 key的类型错误，keyby(1) 或者keyby(“id’)是key的类型为元组
• 2.2 keyby(_._2),key类型为输入类型

本文来源 互联网收集，文章内容系作者个人观点，不代表 本站 对观点赞同或支持。如需转载，请注明文章来源,如您发现有涉嫌抄袭侵权的内容，请联系本站核实处理。