flink-user-zh mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From Lee Djeng <lee.ro...@gmail.com>
Subject Re: 动态处理字段动态sink
Date Thu, 02 Apr 2020 12:03:18 GMT
CEP干这活不合适嘛

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

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