search

apache / rocketmq-streams

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

[RIP-35] Use rocketmq instead of mysql as state store #132

Closed ni-ze closed 2 years ago

ni-ze commented 2 years ago

https://github.com/apache/rocketmq-streams/issues/131

codecov-commenter commented 2 years ago

Codecov Report

Merging #132 (e5fd612) into main (8ba8e00) will not change coverage. The diff coverage is 0.00%.

@@           Coverage Diff           @@
##            main    #132     +/-   ##
=======================================
  Coverage   0.00%   0.00%             
=======================================
  Files        713     650     -63     
  Lines      35571   31951   -3620     
  Branches    5924    5403    -521     
=======================================
+ Misses     35571   31951   -3620
Impacted Files Coverage Δ
...org/apache/rocketmq/streams/sink/RocketMQSink.java 0.00% <0.00%> (ø)
...ketmq/streams/source/MessageListenerDelegator.java 0.00% <0.00%> (ø)
...apache/rocketmq/streams/source/RocketMQSource.java 0.00% <0.00%> (ø)
...cketmq/streams/client/source/DataStreamSource.java 0.00% <0.00%> (ø)
.../rocketmq/streams/client/transform/DataStream.java 0.00% <0.00%> (ø)
.../rocketmq/streams/client/transform/JoinStream.java 0.00% <0.00%> (ø)
...cketmq/streams/common/channel/AbstractChannel.java 0.00% <0.00%> (ø)
.../streams/common/channel/source/AbstractSource.java 0.00% <0.00%> (ø)
...rocketmq/streams/common/utils/CreateTopicUtil.java 0.00% <0.00%> (ø)
.../apache/rocketmq/streams/common/utils/SQLUtil.java 0.00% <0.00%> (ø)
... and 51 more

Continue to review full report at Codecov.

Legend - Click here to learn more Δ = absolute <relative> (impact), ø = not affected, ? = missing data Powered by Codecov. Last update 8ba8e00...e5fd612. Read the comment docs.