This is an automated email from the ASF dual-hosted git repository.
karp pushed a change to branch develop
in repository https://gitbox.apache.org/repos/asf/rocketmq-streams.git
from e2420190 polish(example) add log
new 81dbfadf 为 RocksDB 增加状态的 ColumnFamily 状态于 RocksDB 中的增删改查通过
ColumnFamily 进行隔离
new 31bbe095 Merge branch 'develop' into add_column_family
new c684decf Merge branch 'develop' into add_column_family
new f4f5df03 jobId 增加校验 修改 columnFamily 相关函数
new db7f4589 去除无用的接口方法
new 07d90dde Merge pull request #306 from starmilkxin/add_column_family
The 801 revisions listed above as "new" are entirely new to this
repository and will be described in separate emails. The revisions
listed as "add" were already present in the repository and have only
been added to this reference.
Summary of changes:
.../function/supplier/AccumulatorSupplier.java | 5 +-
.../core/function/supplier/AggregateSupplier.java | 5 +-
.../function/supplier/JoinAggregateSupplier.java | 7 ++-
.../streams/core/rstream/StreamBuilder.java | 11 +++-
.../core/running/AbstractWindowProcessor.java | 5 +-
.../rocketmq/streams/core/state/RocketMQStore.java | 22 +++----
.../rocketmq/streams/core/state/RocksDBStore.java | 38 +++++------
.../rocketmq/streams/core/state/StateStore.java | 5 +-
.../streams/core/util/ColumnFamilyUtil.java | 73 ++++++++++++++++++++++
.../rocketmq/streams/core/window/WindowStore.java | 10 +--
.../streams/core/window/fire/JoinWindowFire.java | 3 +-
.../streams/core/state/RocksDBStoreTest.java | 9 +--
.../rocketmq/streams/examples/WordCount.java | 2 +-
.../streams/examples/joinWindow/JoinWindow.java | 2 +-
.../examples/joinWindow/JoinWithoutWindow.java | 2 +-
.../rocketmq/streams/examples/pojo/Demo.java | 2 +-
.../rocketmq/streams/examples/pojo/User.java | 7 +++
.../streams/examples/sink/WordCountSink.java | 2 +-
.../examples/window/SessionWindowCount.java | 2 +-
.../streams/examples/window/SlideWindowCount.java | 2 +-
.../streams/examples/window/WindowAvg.java | 2 +-
.../streams/examples/window/WindowCount.java | 2 +-
.../streams/examples/window/WindowMin.java | 2 +-
.../streams/examples/window/WindowOrderCount.java | 6 +-
.../streams/examples/window/WindowSum.java | 2 +-
.../streams/examples/window/WindowWordCount.java | 2 +-
26 files changed, 153 insertions(+), 77 deletions(-)
create mode 100644
core/src/main/java/org/apache/rocketmq/streams/core/util/ColumnFamilyUtil.java
