状态编程通常使用几种基础类型即可,但是特殊情况我们可能出现
ValueState> #TUPLE类型
代码记录 使用map作为两种的显示,大家可以一眼看出
private MapState> mapState; private MapState timeStateMap; public MyTempWarning(long timestamp) { this.timestamp = timestamp; } @Override public void open(Configuration parameters) throws Exception { mapState = getRuntimeContext().getMapState( new MapStateDescriptor >( "mapstate", TypeInformation.of(new TypeHint () {}), TypeInformation.of(new TypeHint >() {})) ); timeStateMap = getRuntimeContext().getMapState(new MapStateDescriptor ("timestatemap", Long.class, Long.class)); }



