This is an automated email from the ASF dual-hosted git repository.
jin pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/incubator-hugegraph.git
from b4bc1f066 feat(store): integrate `store-rocksdb` submodule (#2513)
add 43cae1d2e feat(pd): integrate `pd-core` into hugegraph (#2478)
No new revisions were added by this update.
Summary of changes:
.../hg-pd-core}/pom.xml | 63 +-
.../org/apache/hugegraph/pd/ConfigService.java | 137 ++
.../java/org/apache/hugegraph/pd/IdService.java | 82 +
.../java/org/apache/hugegraph/pd/KvService.java | 316 ++++
.../java/org/apache/hugegraph/pd/LogService.java | 67 +
.../hugegraph/pd/PartitionInstructionListener.java | 53 +
.../org/apache/hugegraph/pd/PartitionService.java | 1562 ++++++++++++++++++++
.../hugegraph/pd/PartitionStatusListener.java | 17 +-
.../org/apache/hugegraph/pd/RegistryService.java} | 25 +-
.../hugegraph/pd/ShardGroupStatusListener.java | 14 +-
.../hugegraph/pd/StoreMonitorDataService.java | 265 ++++
.../org/apache/hugegraph/pd/StoreNodeService.java | 1073 ++++++++++++++
.../apache/hugegraph/pd/StoreStatusListener.java} | 15 +-
.../apache/hugegraph/pd/TaskScheduleService.java | 845 +++++++++++
.../org/apache/hugegraph/pd/config/PDConfig.java | 281 ++++
.../apache/hugegraph/pd/meta/ConfigMetaStore.java | 71 +
.../hugegraph/pd/meta/DiscoveryMetaStore.java | 105 ++
.../org/apache/hugegraph/pd/meta/IdMetaStore.java | 254 ++++
.../java/org/apache/hugegraph/pd/meta/LogMeta.java | 48 +
.../apache/hugegraph/pd/meta/MetadataFactory.java | 86 ++
.../hugegraph/pd/meta/MetadataKeyHelper.java | 379 +++++
.../hugegraph/pd/meta/MetadataRocksDBStore.java | 184 +++
.../hugegraph/pd/meta/MetadataStoreBase.java | 123 ++
.../apache/hugegraph/pd/meta/PartitionMeta.java | 295 ++++
.../org/apache/hugegraph/pd/meta/QueueStore.java | 57 +
.../apache/hugegraph/pd/meta/StoreInfoMeta.java | 207 +++
.../org/apache/hugegraph/pd/meta/TaskInfoMeta.java | 133 ++
.../hugegraph/pd/raft/FutureClosureAdapter.java | 36 +-
.../org/apache/hugegraph/pd/raft/KVOperation.java | 161 ++
.../apache/hugegraph/pd/raft/KVStoreClosure.java | 16 +-
.../org/apache/hugegraph/pd/raft/RaftEngine.java | 378 +++++
.../apache/hugegraph/pd/raft/RaftRpcClient.java | 88 ++
.../apache/hugegraph/pd/raft/RaftRpcProcessor.java | 130 ++
.../hugegraph/pd/raft/RaftStateListener.java} | 5 +-
.../apache/hugegraph/pd/raft/RaftStateMachine.java | 329 +++++
.../apache/hugegraph/pd/raft/RaftTaskHandler.java | 12 +-
.../org/apache/hugegraph/pd/raft}/ZipUtils.java | 14 +-
.../hugegraph/pd/store/BaseKVStoreClosure.java | 32 +-
.../org/apache/hugegraph/pd/store/HgKVStore.java | 59 +
.../apache/hugegraph/pd/store/HgKVStoreImpl.java | 343 +++++
.../java/org/apache/hugegraph/pd/store/KV.java} | 27 +-
.../org/apache/hugegraph/pd/store/RaftKVStore.java | 322 ++++
hugegraph-pd/hg-pd-test/pom.xml | 10 +
hugegraph-pd/pom.xml | 3 +-
44 files changed, 8595 insertions(+), 127 deletions(-)
copy {hugegraph-store/hg-store-rocksdb => hugegraph-pd/hg-pd-core}/pom.xml
(59%)
create mode 100644
hugegraph-pd/hg-pd-core/src/main/java/org/apache/hugegraph/pd/ConfigService.java
create mode 100644
hugegraph-pd/hg-pd-core/src/main/java/org/apache/hugegraph/pd/IdService.java
create mode 100644
hugegraph-pd/hg-pd-core/src/main/java/org/apache/hugegraph/pd/KvService.java
create mode 100644
hugegraph-pd/hg-pd-core/src/main/java/org/apache/hugegraph/pd/LogService.java
create mode 100644
hugegraph-pd/hg-pd-core/src/main/java/org/apache/hugegraph/pd/PartitionInstructionListener.java
create mode 100644
hugegraph-pd/hg-pd-core/src/main/java/org/apache/hugegraph/pd/PartitionService.java
copy
hugegraph-store/hg-store-client/src/main/java/org/apache/hugegraph/store/HgKvIterator.java
=>
hugegraph-pd/hg-pd-core/src/main/java/org/apache/hugegraph/pd/PartitionStatusListener.java
(74%)
copy
hugegraph-pd/{hg-pd-client/src/main/java/org/apache/hugegraph/pd/client/Discoverable.java
=> hg-pd-core/src/main/java/org/apache/hugegraph/pd/RegistryService.java} (54%)
copy
hugegraph-server/hugegraph-core/src/main/java/org/apache/hugegraph/backend/Transaction.java
=>
hugegraph-pd/hg-pd-core/src/main/java/org/apache/hugegraph/pd/ShardGroupStatusListener.java
(75%)
create mode 100644
hugegraph-pd/hg-pd-core/src/main/java/org/apache/hugegraph/pd/StoreMonitorDataService.java
create mode 100644
hugegraph-pd/hg-pd-core/src/main/java/org/apache/hugegraph/pd/StoreNodeService.java
copy
hugegraph-pd/{hg-pd-client/src/main/java/org/apache/hugegraph/pd/client/Discoverable.java
=> hg-pd-core/src/main/java/org/apache/hugegraph/pd/StoreStatusListener.java}
(65%)
create mode 100644
hugegraph-pd/hg-pd-core/src/main/java/org/apache/hugegraph/pd/TaskScheduleService.java
create mode 100644
hugegraph-pd/hg-pd-core/src/main/java/org/apache/hugegraph/pd/config/PDConfig.java
create mode 100644
hugegraph-pd/hg-pd-core/src/main/java/org/apache/hugegraph/pd/meta/ConfigMetaStore.java
create mode 100644
hugegraph-pd/hg-pd-core/src/main/java/org/apache/hugegraph/pd/meta/DiscoveryMetaStore.java
create mode 100644
hugegraph-pd/hg-pd-core/src/main/java/org/apache/hugegraph/pd/meta/IdMetaStore.java
create mode 100644
hugegraph-pd/hg-pd-core/src/main/java/org/apache/hugegraph/pd/meta/LogMeta.java
create mode 100644
hugegraph-pd/hg-pd-core/src/main/java/org/apache/hugegraph/pd/meta/MetadataFactory.java
create mode 100644
hugegraph-pd/hg-pd-core/src/main/java/org/apache/hugegraph/pd/meta/MetadataKeyHelper.java
create mode 100644
hugegraph-pd/hg-pd-core/src/main/java/org/apache/hugegraph/pd/meta/MetadataRocksDBStore.java
create mode 100644
hugegraph-pd/hg-pd-core/src/main/java/org/apache/hugegraph/pd/meta/MetadataStoreBase.java
create mode 100644
hugegraph-pd/hg-pd-core/src/main/java/org/apache/hugegraph/pd/meta/PartitionMeta.java
create mode 100644
hugegraph-pd/hg-pd-core/src/main/java/org/apache/hugegraph/pd/meta/QueueStore.java
create mode 100644
hugegraph-pd/hg-pd-core/src/main/java/org/apache/hugegraph/pd/meta/StoreInfoMeta.java
create mode 100644
hugegraph-pd/hg-pd-core/src/main/java/org/apache/hugegraph/pd/meta/TaskInfoMeta.java
copy
hugegraph-server/hugegraph-core/src/main/java/org/apache/hugegraph/type/define/Frequency.java
=>
hugegraph-pd/hg-pd-core/src/main/java/org/apache/hugegraph/pd/raft/FutureClosureAdapter.java
(56%)
create mode 100644
hugegraph-pd/hg-pd-core/src/main/java/org/apache/hugegraph/pd/raft/KVOperation.java
copy
hugegraph-server/hugegraph-core/src/main/java/org/apache/hugegraph/job/computer/Computer.java
=>
hugegraph-pd/hg-pd-core/src/main/java/org/apache/hugegraph/pd/raft/KVStoreClosure.java
(73%)
create mode 100644
hugegraph-pd/hg-pd-core/src/main/java/org/apache/hugegraph/pd/raft/RaftEngine.java
create mode 100644
hugegraph-pd/hg-pd-core/src/main/java/org/apache/hugegraph/pd/raft/RaftRpcClient.java
create mode 100644
hugegraph-pd/hg-pd-core/src/main/java/org/apache/hugegraph/pd/raft/RaftRpcProcessor.java
copy
hugegraph-pd/{hg-pd-client/src/main/java/org/apache/hugegraph/pd/watch/PDWatcher.java
=>
hg-pd-core/src/main/java/org/apache/hugegraph/pd/raft/RaftStateListener.java}
(88%)
create mode 100644
hugegraph-pd/hg-pd-core/src/main/java/org/apache/hugegraph/pd/raft/RaftStateMachine.java
copy
hugegraph-store/hg-store-client/src/main/java/org/apache/hugegraph/store/client/grpc/KvCloseableIterator.java
=>
hugegraph-pd/hg-pd-core/src/main/java/org/apache/hugegraph/pd/raft/RaftTaskHandler.java
(77%)
copy
{hugegraph-store/hg-store-rocksdb/src/main/java/org/apache/hugegraph/rocksdb/access/util
=>
hugegraph-pd/hg-pd-core/src/main/java/org/apache/hugegraph/pd/raft}/ZipUtils.java
(88%)
copy
hugegraph-store/hg-store-client/src/main/java/org/apache/hugegraph/store/client/grpc/KvListIterator.java
=>
hugegraph-pd/hg-pd-core/src/main/java/org/apache/hugegraph/pd/store/BaseKVStoreClosure.java
(62%)
create mode 100644
hugegraph-pd/hg-pd-core/src/main/java/org/apache/hugegraph/pd/store/HgKVStore.java
create mode 100644
hugegraph-pd/hg-pd-core/src/main/java/org/apache/hugegraph/pd/store/HgKVStoreImpl.java
copy
hugegraph-pd/{hg-pd-client/src/main/java/org/apache/hugegraph/pd/watch/WatchType.java
=> hg-pd-core/src/main/java/org/apache/hugegraph/pd/store/KV.java} (66%)
create mode 100644
hugegraph-pd/hg-pd-core/src/main/java/org/apache/hugegraph/pd/store/RaftKVStore.java
