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

Tue, 09 Jun 2020 03:28:09 -0700 

Hi


????????TypeInformation a = 
TypeInformation.of(OrderState.class);??????????pojo????????????pojo??????????????????????????????????????


Best,
Yichao Yang





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

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




OrderState ????????????????????
???????????????????? get set ?????? 

???????? flink ??????????????OrderState??????????????



wang...@geekplus.com.cn

???????? 1048262223
?????????? 2020-06-09 18:11
???????? user-zh
?????? ??????Flink State ?????????? state ????????????
Hi
&nbsp;
&nbsp;
????????flink??????????????OrderState????????????????????????pojo??????????savepoint??????????????????????????????????????????
&nbsp;
Best,
Yichao Yang
&nbsp;
&nbsp;
&nbsp;
&nbsp;
------------------&amp;nbsp;????????&amp;nbsp;------------------
??????:&amp;nbsp;"wangl...@geekplus.com.cn"<wangl...@geekplus.com.cn&amp;gt;;
????????:&amp;nbsp;2020??6??9??(??????) ????6:03
??????:&amp;nbsp;"user-zh"<user-zh@flink.apache.org&amp;gt;;
&nbsp;
????:&amp;nbsp;Flink State ?????????? state ????????????
&nbsp;
&nbsp;
&nbsp;
&nbsp;
?????????????????? Flink State ????????
&nbsp;
public class OrderState {
&amp;nbsp;&amp;nbsp;&amp;nbsp; private Integer warehouseId;
&amp;nbsp;&amp;nbsp;&amp;nbsp; private String orderNo;
&amp;nbsp;&amp;nbsp;&amp;nbsp; private String ownerCode;
&amp;nbsp;&amp;nbsp;&amp;nbsp; private Long inputDate;
&amp;nbsp;&amp;nbsp;&amp;nbsp; private int orderType;
&amp;nbsp;&amp;nbsp;&amp;nbsp; private int amount = 0;
&amp;nbsp;&amp;nbsp;&amp;nbsp; private int status = 0;
.............
}
&nbsp;
&nbsp;
??????????????????????????????????????????????state ??????????????
?????? flink run -s&amp;nbsp;&amp;nbsp; savepointdir&amp;nbsp;&amp;nbsp; 
?????????????????????????? state ????
&nbsp;
??????
????
&nbsp;
&nbsp;
&nbsp;
wangl...@geekplus.com.cn

回复