search

apache / rocketmq-streams

Apache rocketmq
https://rocketmq.apache.org/
Apache License 2.0
171 stars 82 forks source link

加一个算子，类似在.count().toSink() #156

Closed yinrong2022 closed 2 years ago

yinrong2022 commented 2 years ago

把原始日志备份到期望的存储，系统自动加上窗口的开始时间，结束时间，如果需要额外的字段扩展，也可以在这个算子操作原始日志加期望的字段