所谓“泛型”,我的意思是能够接受任何类型的对象作为输入,并返回相同的对象作为输出。
假设函数的任务是将每个元素序列化为json,并将其作为一个边输出写入。
class MyProcessFunction() extends ProcessFunction[? , ?] {
def processElement(element: ?, ctx: ProcessFunction[?, ?]#Context, out: Collector[?]): Unit = ???
...
}
我是否可以这样定义它:它将被不同类型的输入使用?
1条答案
按热度按时间iswrvxsc1#
你可以通过使你的类成为泛型来做到这一点。所以,你会有这样的结果:
这样,您就可以在创建函数示例时确定类型。