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

[1048262223]

Hi


????????????????????????????????????[1]


[1]https://ci.apache.org/projects/flink/flink-docs-master/zh/dev/stream/state/schema_evolution.html#pojo-%E7%B1%BB%E5%9E%8B


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