??????Flink State ?????????? state ????????????

[1048262223]

Hi


????????flink??????????????OrderState????????????????????????pojo??????????savepoint??????????????????????????????????????????

Best,
Yichao Yang




------------------ ???????? ------------------
??????:&nbsp;"wangl...@geekplus.com.cn"<wangl...@geekplus.com.cn&gt;;
????????:&nbsp;2020??6??9??(??????) ????6:03
??????:&nbsp;"user-zh"<user-zh@flink.apache.org&gt;;

????:&nbsp;Flink State ?????????? state ????????????




?????????????????? Flink State ????????

public class OrderState {
&nbsp;&nbsp;&nbsp; private Integer warehouseId;
&nbsp;&nbsp;&nbsp; private String orderNo;
&nbsp;&nbsp;&nbsp; private String ownerCode;
&nbsp;&nbsp;&nbsp; private Long inputDate;
&nbsp;&nbsp;&nbsp; private int orderType;
&nbsp;&nbsp;&nbsp; private int amount = 0;
&nbsp;&nbsp;&nbsp; private int status = 0;
.............
}


??????????????????????????????????????????????state ??????????????
?????? flink run -s&nbsp;&nbsp; savepointdir&nbsp;&nbsp; 
?????????????????????????? state ????

??????
????



wangl...@geekplus.com.cn