回复：动态处理字段动态sink

[出发 <57...@qq.com>]

sql最香





------------------ 原始邮件 ------------------
发件人: Lee Djeng <lee.roval@gmail.com&gt;
发送时间: 2020年4月2日 20:03
收件人: user-zh <user-zh@flink.apache.org&gt;
主题: 回复：动态处理字段动态sink



CEP干这活不合适嘛

出发 <573693104@qq.com&gt; 于2020年4月2日周四 下午7:54写道：

&gt; 感谢大佬们的流转sql，我突然想到，不能去规则引擎考虑问题，用sql不就好了
&gt; ------------------&amp;nbsp;原始邮件&amp;nbsp;------------------
&gt; 发件人:&amp;nbsp;"出发&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; "<573693104@qq.com&amp;gt;;
&gt; 发送时间:&amp;nbsp;2020年4月2日(星期四) 下午4:57
&gt; 收件人:&amp;nbsp;"user-zh"<user-zh@flink.apache.org&amp;gt;;
&gt;
&gt; 主题:&amp;nbsp;回复： 动态处理字段动态sink
&gt;
&gt;
&gt;
&gt; 动态广播是获得了我配置的规则，就是这个规则如何解析实现，没有太好思路，目前只有查到一个drools。
&gt;
&gt;
&gt;
&gt;
&gt; ------------------&amp;amp;nbsp;原始邮件&amp;amp;nbsp;------------------
&gt; 发件人:&amp;amp;nbsp;"Jun Zhang"<zhangjunemail100@gmail.com&amp;amp;gt;;
&gt; 发送时间:&amp;amp;nbsp;2020年4月2日(星期四) 下午4:41
&gt; 收件人:&amp;amp;nbsp;"user-zh"<user-zh@flink.apache.org&amp;amp;gt;;
&gt;
&gt; 主题:&amp;amp;nbsp;Re: 动态处理字段动态sink
&gt;
&gt;
&gt;
&gt; hi:
&gt; 不知道广播流能否满足你的需求
&gt;
&gt; 出发 <573693104@qq.com&amp;amp;gt; 于2020年4月2日周四 下午4:25写道：
&gt;
&gt; &amp;amp;gt;
&gt; &amp;amp;gt;
&gt; 老铁们，消费kafka一些数据时候，根据规则，将满足条件的一些字段生成新字段，插入到es或者pg等里面，其中映射字段是动态的，插入字段也是动态的，结合drools来做比较好吗。