转发:flink 设置broadcastStream 的MapStateDescriptor

classic Classic list List threaded Threaded
3 messages Options
smq
Reply | Threaded
Open this post in threaded view
|

转发:flink 设置broadcastStream 的MapStateDescriptor

smq
发自我的iPhone


------------------ 原始邮件 ------------------
发件人: 明启 孙 <[hidden email]&gt;
发送时间: 2021年1月18日 11:30
收件人: user-zh <[hidden email]&gt;
主题: 转发:flink 设置broadcastStream 的MapStateDescriptor



 
大家好:

&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; MapStateDescriptor (String name, TypeInformation<UK&gt; keyTypeInfo, TypeInformation<UV&gt; valueTypeInfo)中的第二个参数key值得是什么,其中value指的是状态值,在网上看到key大部分用的是String类型,不知道这个key是根据什么指定的。

&nbsp;

smq

&nbsp;
Reply | Threaded
Open this post in threaded view
|

Re: flink 设置broadcastStream 的MapStateDescriptor

nobleyd
key和value都是你自己设置的,看你需要设置什么类型哈。这个不是强制的。
你的map state的key和value在具体业务场景下需要什么类型,那个地方就设置什么类型的TypeInformation,懂吧。

smq <[hidden email]> 于2021年1月18日周一 下午12:18写道:

> 发自我的iPhone
>
>
> ------------------ 原始邮件 ------------------
> 发件人: 明启 孙 <[hidden email]&gt;
> 发送时间: 2021年1月18日 11:30
> 收件人: user-zh <[hidden email]&gt;
> 主题: 转发:flink 设置broadcastStream 的MapStateDescriptor
>
>
>
>
> 大家好:
>
> &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; MapStateDescriptor (String name,
> TypeInformation<UK&gt; keyTypeInfo, TypeInformation<UV&gt;
> valueTypeInfo)中的第二个参数key值得是什么,其中value指的是状态值,在网上看到key大部分用的是String类型,不知道这个key是根据什么指定的。
>
> &nbsp;
>
> smq
>
> &nbsp;
smq
Reply | Threaded
Open this post in threaded view
|

回复:flink 设置broadcastStream 的MapStateDescriptor

smq
多谢,刚开始理解有问题



发自我的iPhone


------------------ 原始邮件 ------------------
发件人: 赵一旦 <[hidden email]&gt;
发送时间: 2021年1月18日 15:56
收件人: user-zh <[hidden email]&gt;
主题: 回复:flink 设置broadcastStream 的MapStateDescriptor



key和value都是你自己设置的,看你需要设置什么类型哈。这个不是强制的。
你的map state的key和value在具体业务场景下需要什么类型,那个地方就设置什么类型的TypeInformation,懂吧。

smq <[hidden email]&gt; 于2021年1月18日周一 下午12:18写道:

&gt; 发自我的iPhone
&gt;
&gt;
&gt; ------------------ 原始邮件 ------------------
&gt; 发件人: 明启 孙 <[hidden email]&amp;gt;
&gt; 发送时间: 2021年1月18日 11:30
&gt; 收件人: user-zh <[hidden email]&amp;gt;
&gt; 主题: 转发:flink 设置broadcastStream 的MapStateDescriptor
&gt;
&gt;
&gt;
&gt;
&gt; 大家好:
&gt;
&gt; &amp;nbsp;&amp;nbsp;&amp;nbsp;&amp;nbsp;&amp;nbsp;&amp;nbsp; MapStateDescriptor (String name,
&gt; TypeInformation<UK&amp;gt; keyTypeInfo, TypeInformation<UV&amp;gt;
&gt; valueTypeInfo)中的第二个参数key值得是什么,其中value指的是状态值,在网上看到key大部分用的是String类型,不知道这个key是根据什么指定的。
&gt;
&gt; &amp;nbsp;
&gt;
&gt; smq
&gt;
&gt; &amp;nbsp;