flink的OutPutTag如何保存一个类的泛型
时间: 2023-07-04 13:09:59 浏览: 127
实时数仓flink ClickHouse工具类
在 Flink 中使用 OutPutTag 时,需要注意一下几点:
1. OutPutTag 可以用来标记一个流中的某些元素,这些元素可以被发送到另外一个流中;
2. 使用 OutPutTag 时需要指定一个类型参数,表示标记的类型;
3. 在 Flink 中,OutPutTag 的类型参数必须是一个具体的类型,不能是一个泛型类型。
因此,如果想要在 OutPutTag 中保存一个类的泛型,可以使用 Java 的通配符类型来实现。例如:
```java
public class MyOutputTag<T> extends OutputTag<MyClass<? extends T>> {}
```
这里的 `MyClass` 是一个包含泛型的类,`? extends T` 表示这个泛型类型的上界是 T。这样定义之后,就可以使用 `MyOutputTag` 来标记一个流中的元素,并且这些元素的类型可以是任意类型,只要是 `MyClass` 的子类即可。
阅读全文