回复：全局state

Tue, 26 May 2020 09:03:28 -0700 

hi
你的意思是说两条数据
第一条的id等于第二条的id
或者
第一条的name等于第二条的name
则映射成同一个
keyby的方式我不知道能不能满足你的需求


但我理解如果id和name不是随机的话，有映射关系的话可以尝试了解广播




------------------ 原始邮件 ------------------
发件人: tison <[email protected]&gt;
发送时间: 2020年5月26日 19:01
收件人: user-zh <[email protected]&gt;
主题: 回复：全局state



任意并行度全局状态从物理上就是不可行的，你可以了解一下分布式计算系统怎么部署物理作业的。“全局状态”要么依赖外部存储要么依赖实现（部署）细节。

你这个需求能不能自定义 KeyBy 细节（KeySelector）来实现？相关文档见
https://ci.apache.org/projects/flink/flink-docs-release-1.10/dev/api_concepts.html#define-keys-using-key-selector-functions

Best,
tison.


star <[email protected]&gt; 于2020年5月26日周二 下午6:42写道：

&gt; 
请问，有全局状态组件吗？我有一个需求需要对数据里的id和name做映射，也就是如果两条数据的id或者name相同则映射成一个值；现在只能使用operator
&gt; state，并且并行度设置为1，来实现全局state
&gt;
&gt;
&gt; 谢谢
&gt;
&gt; 发自我的iPhone

回复