Re: 动态处理字段动态sink

Thu, 02 Apr 2020 05:03:52 -0700 

CEP干这活不合适嘛

出发 <[email protected]> 于2020年4月2日周四 下午7:54写道：

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

回复