问题:

在Aggregate状态获取时,为了方便起见可以将聚合函数简化为Tuple2<Integer, Long>类型,但是Tuple2<Integer, Long>的类型如何表示呢?

解决:

表示方式如下:

 Types.TUPLE(Types.INT, Types.LONG)

valueState = getRuntimeContext()
.getState(new ValueStateDescriptor<TreeSet<HotItem>>(
"valueState",TypeInformation.of(new TypeHint<TreeSet<HotItem>>() { })));

总结:

1.其实万能的方法就是使用TypeInformation.of(new TypeHint<TreeSet<HotItem>>() { }
2.记得最后加上{},防止泛型擦除