Google Git Google Git
Sign in
apache/rocketmq-streams/HEAD
  1. 22976de Merge pull request #276 from Jargon9/develop_consume_first by Ni Ze · 3 years, 2 months ago develop
  2. 07d90dd Merge pull request #306 from starmilkxin/add_column_family by Ni Ze · 3 years, 2 months ago
  3. db7f458 去除无用的接口方法 by starmilkxin · 3 years, 2 months ago
  4. f4f5df0 jobId 增加校验 修改 columnFamily 相关函数 by starmilkxin · 3 years, 3 months ago
  5. f5182aa [ISSUE #272] use admin reset offset by Jargon · 3 years, 3 months ago
  6. 62f724d [ISSUE #272] add exception handle by Jargon · 3 years, 3 months ago
  7. 4928260 [ISSUE #272] remove debug log by Jargon · 3 years, 3 months ago
  8. d90d275 Merge branch 'develop' into develop_consume_first by Jargon · 3 years, 3 months ago
  9. ebf53b3 [ISSUE #272] use admin to reset offset by Jargon · 3 years, 3 months ago
  10. c684dec Merge branch 'develop' into add_column_family by starmilkxin · 3 years, 3 months ago
  11. e242019 polish(example) add log by karp · 3 years, 3 months ago
  12. 5050374 fix(bug) session window not right by karp · 3 years, 3 months ago
  13. ef30dd1 add watermark in IdleWindowScaner by starmilkxin · 3 years, 5 months ago
  14. ef51008 Merge pull request #297 from elenacliu/hopping by Ni Ze · 3 years, 3 months ago
  15. 31bbe09 Merge branch 'develop' into add_column_family by starmilkxin · 3 years, 3 months ago
  16. 81dbfad 为 RocksDB 增加状态的 ColumnFamily 状态于 RocksDB 中的增删改查通过 ColumnFamily 进行隔离 by starmilkxin · 3 years, 3 months ago
  17. cbf6a92 Merge branch 'apache:develop' into hopping by elenacliu · 3 years, 4 months ago
  18. 4bd58c8 Merge pull request #302 from ni-ze/develop by Ni Ze · 3 years, 4 months ago
  19. 0c51893 fix(bug) npe when process data by karp · 3 years, 4 months ago
  20. af419fd feat: add 2 window examples by elenacliu · 3 years, 4 months ago
  21. 979fdf5 Merge pull request #295 from Shuozeli/develop by Ni Ze · 3 years, 4 months ago
  22. f01fff6 Do not process the data from the removed MessageQueues by removing the queues from the originListener first by Shuoze Li · 3 years, 4 months ago
  23. 14ba8f7 Merge pull request #293 from ni-ze/develop by Ni Ze · 3 years, 5 months ago
  24. 900b260 fix(bug) recover state when rocketmqStreams failed and restart by 维章 · 3 years, 5 months ago
  25. 82ffd2b Merge branch 'local/upstream/develop' into develop by 维章 · 3 years, 5 months ago
  26. 66637a5 Refactor the find largest queueOffset message code to use Java Stream max() api instead of sort. by Shuoze Li · 3 years, 5 months ago
  27. 9bfd1cb Filter the removeQueues from addQueues when recovering the state by Shuoze Li · 3 years, 5 months ago
  28. 7357c27 modify the note by 维章 · 3 years, 5 months ago
  29. f44f1f5 [ISSUE #272]Fix inner topic by Jargon · 3 years, 5 months ago
  30. db84168 polish(code) modify log by 维章 · 3 years, 5 months ago
  31. a69d341 Merge pull request #292 from Shuozeli/develop by Ni Ze · 3 years, 5 months ago
  32. b9e790c Support flatmap function in GroupedStream by Shuoze Li · 3 years, 5 months ago
  33. 0a735fb Merge pull request #288 from ni-ze/develop by Ni Ze · 3 years, 6 months ago
  34. 5f9249b Merge pull request #284 from elenacliu/return_null by Ni Ze · 3 years, 6 months ago
  35. 0503f21 fix: modify the logger info by elenacliu · 3 years, 6 months ago
  36. 036f92e fix(state) fix bug: npl when rebalance by 维章 · 3 years, 6 months ago
  37. 28c1a9a feat: finish data processing when function return null by elenacliu · 3 years, 6 months ago
  38. 8b8aa90 Merge pull request #282 from ni-ze/develop by Ni Ze · 3 years, 6 months ago
  39. dfcff77 polish(example) add constructor by 维章 · 3 years, 6 months ago
  40. a9eec8c Merge branch 'develop_consume_first' of github.com:Jargon9/rocketmq-streams into develop_consume_first by Jargon · 3 years, 6 months ago
  41. 720ede3 [ISSUE #272]Support subscribe topic from first by Jargon96 · 3 years, 8 months ago
  42. 30e29c0 Merge pull request #280 from apache/dependabot/maven/core/com.fasterxml.jackson.core-jackson-databind-2.13.4.2 by Ni Ze · 3 years, 7 months ago
  43. 849a9ba Bump jackson-databind from 2.13.4.1 to 2.13.4.2 in /core by dependabot[bot] · 3 years, 7 months ago
  44. 9453c2f Merge pull request #277 from ni-ze/develop by Ni Ze · 3 years, 8 months ago
  45. 4deecda modify NOTICE file by 维章 · 3 years, 8 months ago
  46. f54df9d [ISSUE #272]Support subscribe topic from first by Jargon96 · 3 years, 8 months ago
  47. fbe1967 Merge pull request #275 from joeCarf/support_min_function by Ni Ze · 3 years, 8 months ago
  48. 4844f3b refactor example by joeCarf · 3 years, 8 months ago
  49. d67903c support sum by joeCarf · 3 years, 8 months ago
  50. 2041582 refactor format by joeCarf · 3 years, 8 months ago
  51. d8c8ad1 Add example by joeCarf · 3 years, 8 months ago
  52. a43e467 Add min & max func by joeCarf · 3 years, 8 months ago
  53. f546c00 Merge pull request #273 from apache/local/upstream/develop by Ni Ze · 3 years, 8 months ago
  54. 159f6b7 [maven-release-plugin] prepare for next development iteration by 维章 · 3 years, 8 months ago
  55. 7b85a18 [maven-release-plugin] prepare release rocketmq-streams-all-1.1.1 by 维章 · 3 years, 8 months ago release-1.1.1 rocketmq-streams-all-1.1.1
  56. ecf01cf Merge pull request #271 from ni-ze/develop by Ni Ze · 3 years, 8 months ago
  57. a256c96 modify the return type of flatmap by 维章 · 3 years, 8 months ago
  58. 9bff38e Merge pull request #269 from ni-ze/develop by Ni Ze · 3 years, 8 months ago
  59. c81b551 modify the num of shuffle topic queue by 维章 · 3 years, 9 months ago
  60. 97e2568 remove redundancy code by 维章 · 3 years, 9 months ago
  61. b6dac32 Merge branch 'local/upstream/develop' into develop by 维章 · 3 years, 9 months ago
  62. b5355de Merge pull request #259 from Jargon9/develop_avg by Ni Ze · 3 years, 9 months ago
  63. 81607e6 remove redundant code by 维章 · 3 years, 9 months ago
  64. ff51011 modify log level by 维章 · 3 years, 9 months ago
  65. 652c9ac Merge branch 'develop' into develop_avg by Ni Ze · 3 years, 9 months ago
  66. 57e31e7 Merge branch 'local/upstream/develop' into develop by 维章 · 3 years, 9 months ago
  67. 7c0ceee Merge pull request #266 from ni-ze/develop by Ni Ze · 3 years, 9 months ago
  68. 854df3a modify schedule thread num by 维章 · 3 years, 9 months ago
  69. 5c7608d modify schedule execute service by 维章 · 3 years, 9 months ago
  70. 2bb863b add example by 维章 · 3 years, 9 months ago
  71. 3e94af3 add log by 维章 · 3 years, 9 months ago
  72. fabc571 Merge branch 'local/upstream/develop' into develop by 维章 · 3 years, 9 months ago
  73. e6eec5d [ISSUE #251] Update windowAvg examples by Jargon96 · 3 years, 9 months ago
  74. 6e17ed8 Merge branch 'develop' into develop_avg by Jargon96 · 3 years, 9 months ago
  75. daf22d7 [ISSUE #251]Support avg function in WindowStream by Jargon96 · 3 years, 9 months ago
  76. af0a846 two stream join 0.2 by 维章 · 3 years, 9 months ago
  77. 47d1c6c two stream join 0.1 by 维章 · 3 years, 9 months ago
  78. fb1a307 persist watermark after fired. by 维章 · 3 years, 9 months ago
  79. 608ccae Merge pull request #264 from ni-ze/develop by Ni Ze · 3 years, 9 months ago
  80. 14c9488 modify the constant by 维章 · 3 years, 9 months ago
  81. c86a723 add watermark in session window by 维章 · 3 years, 9 months ago
  82. b9fe94d Merge pull request #262 from ni-ze/develop by Ni Ze · 3 years, 9 months ago
  83. f891481 modify log level by 维章 · 3 years, 9 months ago
  84. de18512 store watermark by 维章 · 3 years, 9 months ago
  85. 462196f polish example by 维章 · 3 years, 9 months ago
  86. 1dd13c3 modify windowCount example by 维章 · 3 years, 9 months ago
  87. 86f1819 Merge pull request #260 from ni-ze/develop by Ni Ze · 3 years, 9 months ago
  88. d5db2a2 idle window 0.3 by 维章 · 3 years, 9 months ago
  89. 16e1f3e idle window 0.2 by 维章 · 3 years, 9 months ago
  90. ca82d3b idle window 0.1 by 维章 · 3 years, 9 months ago
  91. 2906e9b modify the configure of ObjectMapper. by 维章 · 3 years, 9 months ago
  92. 102cae5 change operator name of groupedstream by 维章 · 3 years, 9 months ago
  93. d6b934a Merge pull request #258 from ni-ze/develop by Ni Ze · 3 years, 9 months ago
  94. 4a6237e move log by 维章 · 3 years, 9 months ago
  95. 51d13d5 Merge pull request #256 from ni-ze/develop by Ni Ze · 3 years, 9 months ago
  96. 45f24e3 modify the name of workeThread by 维章 · 3 years, 9 months ago
  97. 73146ed repeated stop in workerThread by 维章 · 3 years, 9 months ago
  98. 1a93532 Merge branch 'local/upstream/develop' into develop by 维章 · 3 years, 9 months ago
  99. 5e1dd64 use the name of thread as rocksdb path. by 维章 · 3 years, 9 months ago
  100. f499b19 Merge pull request #254 from ni-ze/develop by Ni Ze · 3 years, 9 months ago