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

ni-ze · 2022-02-23T13:23:57Z

duhenglucky · 2022-02-25T05:49:30Z

...s/src/main/java/org/apache/rocketmq/streams/examples/checkpoint/RemoteCheckpointExample.java

-
-}
+///*
+// *


If no need this class file，just delete it directly.

# Conflicts: # rocketmq-streams-dbinit/src/main/resources/tables_mysql_innodb.sql # rocketmq-streams-examples/src/main/java/org/apache/rocketmq/streams/examples/checkpoint/RemoteCheckpointExample.java

codecov-commenter · 2022-06-28T16:29:39Z

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.

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

ni-ze added 13 commits January 4, 2022 16:34

fix(example) make example RemoteCheckpointTest correct.

5bbf900

Merge branch 'main' into develop

81dd0aa

feat(storage) replace db with kv, version 0.1

e6f0c87

feat(storage) replace db with kv, version 0.2

65553b7

feat(storage) replace db with kv, version 0.3

0c4b382

feat(storage) replace db with kv, version 0.4

f8b0307

feat(storage) replace db with kv, version 0.5

33267bc

feat(storage) replace db with kv, version 0.6

f1b2ab0

feat(storage) replace db with kv, version 0.7

dbec220

feat(storage) replace db with kv, version 1.0

6d17db1

merge from main.

da18dc0

feat(storage) replace db with kv,delete dbinit and sqlcache, version 1.1

e09afbd

feat(storage) replace db with kv,simplify codeg, version 1.1

790ce6b

duhenglucky reviewed Feb 25, 2022

View reviewed changes

ni-ze added 5 commits February 25, 2022 15:20

chore(example) remove useless code

5bfa2df

chore(window) remove windowInstanceKey

fc0957b

feat(storage) delete from rocksdb

cc63239

feat(example) modify example

a709d8a

fix(jar) make rocketmq-streams runnable as a sdk

ed7fa7f

ni-ze force-pushed the replaceDB branch from 0930ce6 to ed7fa7f Compare March 1, 2022 14:06

ni-ze added 10 commits March 3, 2022 14:20

feat(example) use two DefaultLitePullConsumer instance

33cad08

feat(pullConsumer) version 0.1

e251857

feat(fix conflicts)

56a510c

feat(pullConsumer) version 0.2

a834ba5

feat(pullConsumer) version 0.3

bd03a86

Merge branch 'replaceDB' into pullConsumer

c64d552

feat(pullConsumer) version 0.4

86db909

feat(pullConsumer) remove useless file

672005b

merge from main

0c2dd8b

merge from main

f4d2f44

ni-ze added 5 commits May 7, 2022 17:14

merge from replaceDB

eb76b4e

feat(replaceDB) modify rocketmq dependency

15e848c

feat(db) remove db dependency besides channel-db

81bf080

fix(bug) remove error test

4be93e8

fix(rocketmqSource) modify pull

09d3076

ni-ze force-pushed the replaceDB branch from ff92d26 to 5a23697 Compare May 30, 2022 07:10

fix(example) join example

d246488

ni-ze force-pushed the replaceDB branch from 5a23697 to d246488 Compare May 31, 2022 03:02

feat(rpchook) add rpchook when create rocket source/sink

dfa0977

ni-ze closed this Jun 1, 2022

ni-ze reopened this Jun 1, 2022

ni-ze added 2 commits June 18, 2022 12:16

Merge branch 'main' into replaceDB

2c1d938

# Conflicts: # rocketmq-streams-dbinit/src/main/resources/tables_mysql_innodb.sql # rocketmq-streams-examples/src/main/java/org/apache/rocketmq/streams/examples/checkpoint/RemoteCheckpointExample.java

merge(main) merge from main

e5fd612

ni-ze merged commit b654e66 into apache:main Jun 29, 2022

ni-ze added a commit to ni-ze/rocketmq-streams that referenced this pull request Oct 7, 2022

Merge pull request apache#132 from ni-ze/replaceDB

b285cac

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

Provide feedback

Saved searches

Use saved searches to filter your results more quickly

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

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

ni-ze commented Feb 23, 2022

duhenglucky Feb 25, 2022

codecov-commenter commented Jun 28, 2022

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

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

Conversation

ni-ze commented Feb 23, 2022

duhenglucky Feb 25, 2022

Choose a reason for hiding this comment

codecov-commenter commented Jun 28, 2022

Codecov Report