0
点赞
收藏
分享

微信扫一扫

关于在flink 状态函数State中使用Tuple类型记录

RJ_Hwang 2022-02-17 阅读 47

状态编程通常使用几种基础类型即可,但是特殊情况我们可能出现

ValueState<Tuple<String>> #TUPLE类型

代码记录 使用map作为两种的显示,大家可以一眼看出

 		private MapState<Long, Tuple5<String, String, String, Long, Long>> mapState;
        private MapState<Long, Long> timeStateMap;
        public MyTempWarning(long timestamp) {
            this.timestamp = timestamp;
        }

        @Override
        public void open(Configuration parameters) throws Exception {
            mapState = getRuntimeContext().getMapState(
                    new MapStateDescriptor<Long, Tuple5<String, String, String, Long, Long>>(
                            "mapstate",
                            TypeInformation.of(new TypeHint<Long>() {}),
                            TypeInformation.of(new TypeHint<Tuple5<String, String, String, Long, Long>>() {}))
            );
            timeStateMap = getRuntimeContext().getMapState(new MapStateDescriptor<Long, Long>("timestatemap", Long.class, Long.class));
        }
举报

相关推荐

0 条评论