This is an automated email from the ASF dual-hosted git repository.
jin pushed a change to branch pd-store
in repository https://gitbox.apache.org/repos/asf/incubator-hugegraph.git
from eb76bc62a chore: allow merge for a string of commits/PR
add d97ba4cb5 history merged until 2023.5.6
add 08f560f38 refact: unify LF line separator
add dd49f3f54 refact: add header & format in test & service & grpc & dist
modules
add 61ecb66e8 refact: add header/format in core & common & clitools &
client modules
add fd13bb436 refact: format root/parent modules & pd-service package name
& rearrange code
add 4166b6f8f chore: search & replace to "org.apache" manually
add bd3d313a1 chore: fix some code problems
add 6a813d2c0 update code to Jun2 2023
add 8ddf8291a build: add flatten plugin and fix dependency version
add ed00d4eb2 build: fix build for community edition compatibility (WIP)
add 6092dc0fc refact: adapt for jraft v1.3.13
add 3ea878c3a refact: GP-2141 handle low speed import - 6.9
add ec0b0e006 refact: GP-2141 handle low speed import - Compile OK
add a37177207 chore: enhance pom & start file
add 7c325c5ef refact: prepare before merge
add 3910af8f5 Merge branch 'pd' into merge-pd
add cbdd65a06 chore: fix pom for submodules in hugegraph-pd
add 1234c110e chore: add apache-rat-plugin for hugegraph-pd
add 84273f209 chore: clean some comment/code
new 4f34d01eb refact(pd): merge branch 'pr/2270' into pd-store
The 1 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:
hugegraph-pd/.gitattributes | 1 +
hugegraph-pd/.gitignore | 13 +
.../.mvn/wrapper/MavenWrapperDownloader.java | 121 ++
hugegraph-pd/.mvn/wrapper/maven-wrapper.jar | Bin 0 -> 50710 bytes
hugegraph-pd/.mvn/wrapper/maven-wrapper.properties | 18 +
hugegraph-pd/README.md | 940 ++++++++++
hugegraph-pd/build-pre.sh | 54 +
hugegraph-pd/build.sh | 39 +
hugegraph-pd/ci.yml | 43 +
hugegraph-pd/conf/hugegraph.license | Bin 0 -> 856 bytes
hugegraph-pd/conf/verify-license.json | 6 +
hugegraph-pd/deploy-release.sh | 25 +
hugegraph-pd/deploy-snapshot.sh | 25 +
hugegraph-pd/hg-pd-client/pom.xml | 73 +
.../apache/hugegraph/pd/client/AbstractClient.java | 265 +++
.../pd/client/AbstractClientStubProxy.java | 72 +
.../org/apache/hugegraph/pd/client/Channels.java | 44 +
.../apache/hugegraph/pd/client/ClientCache.java | 338 ++++
.../apache/hugegraph/pd/client/Discoverable.java | 30 +
.../hugegraph/pd/client/DiscoveryClient.java | 221 +++
.../hugegraph/pd/client/DiscoveryClientImpl.java | 140 ++
.../org/apache/hugegraph/pd/client/KvClient.java | 352 ++++
.../apache/hugegraph/pd/client/LicenseClient.java | 71 +
.../org/apache/hugegraph/pd/client/PDClient.java | 1347 +++++++++++++++
.../org/apache/hugegraph/pd/client/PDConfig.java | 82 +
.../org/apache/hugegraph/pd/client/PDPulse.java | 152 ++
.../apache/hugegraph/pd/client/PDPulseImpl.java | 196 +++
.../org/apache/hugegraph/pd/client/PDWatch.java | 137 ++
.../apache/hugegraph/pd/client/PDWatchImpl.java | 202 +++
.../apache/hugegraph/pd/pulse/PartitionNotice.java | 49 +
.../hugegraph/pd/pulse/PulseServerNotice.java | 35 +
.../org/apache/hugegraph/pd/watch/NodeEvent.java | 99 ++
.../org/apache/hugegraph/pd/watch/PDWatcher.java | 22 +
.../apache/hugegraph/pd/watch/PartitionEvent.java | 93 +
.../org/apache/hugegraph/pd/watch/WatchType.java | 30 +
.../apache/hugegraph/pd/PartitionCacheTest.java | 102 ++
.../org/apache/hugegraph/pd/StoreRegisterTest.java | 135 ++
.../pd/client/DiscoveryClientImplTest.java | 147 ++
.../hugegraph/pd/client/LicenseClientImplTest.java | 127 ++
.../apache/hugegraph/pd/client/PDPulseTest.java | 109 ++
.../apache/hugegraph/pd/client/PDWatchTest.java | 86 +
.../hugegraph/pd/client/test/HgPDTestUtil.java | 92 +
hugegraph-pd/hg-pd-clitools/pom.xml | 74 +
.../org/apache/hugegraph/pd/clitools/Main.java | 85 +
.../org/apache/hugegraph/pd/clitools/MainTest.java | 80 +
hugegraph-pd/hg-pd-common/pom.xml | 54 +
.../org/apache/hugegraph/pd/common/GraphCache.java | 62 +
.../org/apache/hugegraph/pd/common/HgAssert.java | 117 ++
.../org/apache/hugegraph/pd/common/KVPair.java | 132 ++
.../apache/hugegraph/pd/common/PDException.java | 47 +
.../hugegraph/pd/common/PDRuntimeException.java | 49 +
.../apache/hugegraph/pd/common/PartitionCache.java | 460 +++++
.../apache/hugegraph/pd/common/PartitionUtils.java | 47 +
hugegraph-pd/hg-pd-core/pom.xml | 94 +
.../org/apache/hugegraph/pd/ConfigService.java | 135 ++
.../java/org/apache/hugegraph/pd/IdService.java | 82 +
.../java/org/apache/hugegraph/pd/KvService.java | 317 ++++
.../java/org/apache/hugegraph/pd/LogService.java | 67 +
.../hugegraph/pd/PartitionInstructionListener.java | 52 +
.../org/apache/hugegraph/pd/PartitionService.java | 1563 +++++++++++++++++
.../hugegraph/pd/PartitionStatusListener.java | 29 +
.../org/apache/hugegraph/pd/RegistryService.java | 44 +
.../hugegraph/pd/ShardGroupStatusListener.java | 26 +
.../hugegraph/pd/StoreMonitorDataService.java | 266 +++
.../org/apache/hugegraph/pd/StoreNodeService.java | 1074 ++++++++++++
.../apache/hugegraph/pd/StoreStatusListener.java | 31 +
.../apache/hugegraph/pd/TaskScheduleService.java | 853 ++++++++++
.../org/apache/hugegraph/pd/config/PDConfig.java | 277 +++
.../apache/hugegraph/pd/meta/ConfigMetaStore.java | 73 +
.../hugegraph/pd/meta/DiscoveryMetaStore.java | 105 ++
.../org/apache/hugegraph/pd/meta/IdMetaStore.java | 255 +++
.../java/org/apache/hugegraph/pd/meta/LogMeta.java | 48 +
.../apache/hugegraph/pd/meta/MetadataFactory.java | 87 +
.../hugegraph/pd/meta/MetadataKeyHelper.java | 378 ++++
.../hugegraph/pd/meta/MetadataRocksDBStore.java | 184 ++
.../hugegraph/pd/meta/MetadataStoreBase.java | 124 ++
.../apache/hugegraph/pd/meta/PartitionMeta.java | 295 ++++
.../org/apache/hugegraph/pd/meta/QueueStore.java | 56 +
.../apache/hugegraph/pd/meta/StoreInfoMeta.java | 206 +++
.../org/apache/hugegraph/pd/meta/TaskInfoMeta.java | 132 ++
.../hugegraph/pd/raft/FutureClosureAdapter.java | 48 +
.../org/apache/hugegraph/pd/raft/KVOperation.java | 161 ++
.../apache/hugegraph/pd/raft/KVStoreClosure.java | 33 +
.../org/apache/hugegraph/pd/raft/RaftEngine.java | 377 ++++
.../apache/hugegraph/pd/raft/RaftRpcClient.java | 87 +
.../apache/hugegraph/pd/raft/RaftRpcProcessor.java | 127 ++
.../hugegraph/pd/raft/RaftStateListener.java | 22 +
.../apache/hugegraph/pd/raft/RaftStateMachine.java | 330 ++++
.../apache/hugegraph/pd/raft/RaftTaskHandler.java | 27 +
.../org/apache/hugegraph/pd/raft/ZipUtils.java | 93 +
.../hugegraph/pd/store/BaseKVStoreClosure.java | 48 +
.../org/apache/hugegraph/pd/store/HgKVStore.java | 58 +
.../apache/hugegraph/pd/store/HgKVStoreImpl.java | 343 ++++
.../java/org/apache/hugegraph/pd/store/KV.java | 45 +
.../org/apache/hugegraph/pd/store/RaftKVStore.java | 324 ++++
.../apache/hugegraph/pd/MonitorServiceTest.java | 112 ++
.../apache/hugegraph/pd/PartitionServiceTest.java | 45 +
.../apache/hugegraph/pd/StoreNodeServiceTest.java | 485 ++++++
.../java/org/apache/hugegraph/pd/UnitTestBase.java | 31 +
.../hugegraph/pd/common/PartitionUtilsTest.java | 47 +
.../hugegraph/pd/store/HgKVStoreImplTest.java | 105 ++
.../hg-pd-core/src/test/resources/log4j2.xml | 139 ++
hugegraph-pd/hg-pd-dist/pom.xml | 151 ++
.../src/assembly/descriptor/server-assembly.xml | 57 +
.../src/assembly/static/bin/start-hugegraph-pd.sh | 123 ++
.../src/assembly/static/bin/stop-hugegraph-pd.sh | 49 +
.../hg-pd-dist/src/assembly/static/bin/util.sh | 372 ++++
.../src/assembly/static/conf/application.yml | 78 +
.../assembly/static/conf/application.yml.template | 71 +
.../src/assembly/static/conf/hugegraph.license | Bin 0 -> 856 bytes
.../hg-pd-dist/src/assembly/static/conf/log4j2.xml | 134 ++
.../src/assembly/static/conf/verify-license.json | 6 +
hugegraph-pd/hg-pd-grpc/pom.xml | 138 ++
.../hg-pd-grpc/src/main/proto/discovery.proto | 54 +
hugegraph-pd/hg-pd-grpc/src/main/proto/kv.proto | 126 ++
.../hg-pd-grpc/src/main/proto/metaTask.proto | 48 +
.../hg-pd-grpc/src/main/proto/metapb.proto | 377 ++++
.../hg-pd-grpc/src/main/proto/pd_common.proto | 36 +
.../hg-pd-grpc/src/main/proto/pd_pulse.proto | 155 ++
.../hg-pd-grpc/src/main/proto/pd_watch.proto | 86 +
hugegraph-pd/hg-pd-grpc/src/main/proto/pdpb.proto | 590 +++++++
hugegraph-pd/hg-pd-service/pom.xml | 151 ++
.../org/apache/hugegraph/pd/boot/HugePDServer.java | 43 +
.../pd/license/LicenseVerifierService.java | 426 +++++
.../hugegraph/pd/license/LicenseVerifyManager.java | 77 +
.../apache/hugegraph/pd/metrics/MetricsConfig.java | 44 +
.../org/apache/hugegraph/pd/metrics/PDMetrics.java | 114 ++
.../org/apache/hugegraph/pd/model/DemoModel.java | 73 +
.../hugegraph/pd/model/GraphRestRequest.java | 26 +
.../hugegraph/pd/model/GraphSpaceRestRequest.java | 25 +
.../apache/hugegraph/pd/model/PeerRestRequest.java | 25 +
.../hugegraph/pd/model/PromTargetsModel.java | 90 +
.../pd/model/RegistryQueryRestRequest.java | 30 +
.../hugegraph/pd/model/RegistryRestRequest.java | 33 +
.../hugegraph/pd/model/RegistryRestResponse.java | 33 +
.../apache/hugegraph/pd/model/RestApiResponse.java | 53 +
.../hugegraph/pd/model/StoreRestRequest.java | 25 +
.../hugegraph/pd/model/TimeRangeRequest.java | 26 +
.../hugegraph/pd/notice/NoticeBroadcaster.java | 173 ++
.../pd/pulse/AbstractObserverSubject.java | 223 +++
.../apache/hugegraph/pd/pulse/PDPulseSubject.java | 444 +++++
.../pd/pulse/PartitionHeartbeatSubject.java | 60 +
.../hugegraph/pd/pulse/PdInstructionSubject.java | 56 +
.../apache/hugegraph/pd/pulse/PulseListener.java | 39 +
.../java/org/apache/hugegraph/pd/rest/API.java | 186 ++
.../org/apache/hugegraph/pd/rest/GraphAPI.java | 288 ++++
.../apache/hugegraph/pd/rest/GraphSpaceAPI.java | 99 ++
.../org/apache/hugegraph/pd/rest/IndexAPI.java | 255 +++
.../org/apache/hugegraph/pd/rest/MemberAPI.java | 239 +++
.../org/apache/hugegraph/pd/rest/PartitionAPI.java | 475 ++++++
.../apache/hugegraph/pd/rest/PromTargetsAPI.java | 92 +
.../org/apache/hugegraph/pd/rest/RegistryAPI.java | 202 +++
.../org/apache/hugegraph/pd/rest/ShardAPI.java | 119 ++
.../org/apache/hugegraph/pd/rest/StoreAPI.java | 355 ++++
.../java/org/apache/hugegraph/pd/rest/TaskAPI.java | 101 ++
.../java/org/apache/hugegraph/pd/rest/TestAPI.java | 163 ++
.../hugegraph/pd/service/DiscoveryService.java | 147 ++
.../hugegraph/pd/service/KvServiceGrpcImpl.java | 592 +++++++
.../hugegraph/pd/service/PDPulseService.java | 115 ++
.../apache/hugegraph/pd/service/PDRestService.java | 272 +++
.../org/apache/hugegraph/pd/service/PDService.java | 1796 ++++++++++++++++++++
.../hugegraph/pd/service/PDWatchService.java | 37 +
.../hugegraph/pd/service/PromTargetsService.java | 257 +++
.../apache/hugegraph/pd/service/ServiceGrpc.java | 94 +
.../hugegraph/pd/service/UpgradeService.java | 110 ++
.../hugegraph/pd/upgrade/VersionScriptFactory.java | 57 +
.../hugegraph/pd/upgrade/VersionUpgradeScript.java | 59 +
.../pd/upgrade/scripts/PartitionMetaUpgrade.java | 120 ++
.../pd/upgrade/scripts/TaskCleanUpgrade.java | 65 +
.../org/apache/hugegraph/pd/util/DateUtil.java | 71 +
.../apache/hugegraph/pd/util/HgExecutorUtil.java | 180 ++
.../org/apache/hugegraph/pd/util/HgMapCache.java | 103 ++
.../java/org/apache/hugegraph/pd/util/IdUtil.java | 47 +
.../hugegraph/pd/util/grpc/GRpcServerConfig.java | 44 +
.../hugegraph/pd/util/grpc/StreamObserverUtil.java | 49 +
.../hugegraph/pd/watch/AbstractWatchSubject.java | 164 ++
.../apache/hugegraph/pd/watch/KvWatchSubject.java | 288 ++++
.../hugegraph/pd/watch/NodeChangeSubject.java | 65 +
.../apache/hugegraph/pd/watch/PDWatchSubject.java | 216 +++
.../hugegraph/pd/watch/PartitionChangeSubject.java | 63 +
.../pd/watch/ShardGroupChangeSubject.java | 55 +
.../src/main/resources/application.yml | 80 +
.../hg-pd-service/src/main/resources/banner.txt | 6 +
.../hg-pd-service/src/main/resources/log4j2.xml | 139 ++
.../src/test/java/live/PDServer0.java | 48 +
.../src/test/java/live/PDServer1.java | 47 +
.../src/test/java/live/PDServer2.java | 47 +
.../src/test/java/live/PDServer3.java | 47 +
.../src/test/resources/application-server0.yml | 71 +
.../src/test/resources/application-server1.yml | 71 +
.../src/test/resources/application-server2.yml | 73 +
.../src/test/resources/application-server3.yml | 73 +
.../hg-pd-service/src/test/resources/banner.txt | 6 +
.../hg-pd-service/src/test/resources/log4j2.xml | 139 ++
hugegraph-pd/hg-pd-test/pom.xml | 370 ++++
.../apache/hugegraph/pd/client/BaseClientTest.java | 44 +
.../hugegraph/pd/client/DiscoveryClientTest.java | 79 +
.../apache/hugegraph/pd/client/KvClientTest.java | 121 ++
.../hugegraph/pd/client/PDClientSuiteTest.java | 36 +
.../apache/hugegraph/pd/client/PDClientTest.java | 418 +++++
.../hugegraph/pd/clitools/BaseCliToolsTest.java | 34 +
.../hugegraph/pd/clitools/CliToolsSuiteTest.java | 35 +
.../org/apache/hugegraph/pd/clitools/MainTest.java | 89 +
.../apache/hugegraph/pd/common/BaseCommonTest.java | 33 +
.../hugegraph/pd/common/CommonSuiteTest.java | 43 +
.../apache/hugegraph/pd/common/HgAssertTest.java | 134 ++
.../org/apache/hugegraph/pd/common/KVPairTest.java | 73 +
.../hugegraph/pd/common/MetadataKeyHelperTest.java | 217 +++
.../hugegraph/pd/common/PartitionCacheTest.java | 392 +++++
.../hugegraph/pd/common/PartitionUtilsTest.java | 35 +
.../org/apache/hugegraph/pd/core/BaseCoreTest.java | 74 +
.../apache/hugegraph/pd/core/PDCoreSuiteTest.java | 37 +
.../hugegraph/pd/core/StoreNodeServiceTest.java | 119 ++
.../pd/core/meta/MetadataKeyHelperTest.java | 34 +
.../org/apache/hugegraph/pd/grpc/BaseGrpcTest.java | 36 +
.../apache/hugegraph/pd/grpc/GrpcSuiteTest.java | 33 +
.../hugegraph/pd/service/BaseServerTest.java | 57 +
.../hugegraph/pd/service/ConfigServiceTest.java | 106 ++
.../apache/hugegraph/pd/service/IdServiceTest.java | 109 ++
.../apache/hugegraph/pd/service/KvServiceTest.java | 60 +
.../hugegraph/pd/service/LogServiceTest.java | 54 +
.../hugegraph/pd/service/PartitionServiceTest.java | 133 ++
.../apache/hugegraph/pd/service/PdTestBase.java | 219 +++
.../apache/hugegraph/pd/service/RestApiTest.java | 120 ++
.../hugegraph/pd/service/ServerSuiteTest.java | 42 +
.../pd/service/StoreMonitorDataServiceTest.java | 82 +
.../pd/service/StoreNodeServiceNewTest.java | 64 +
.../hugegraph/pd/service/StoreServiceTest.java | 833 +++++++++
.../pd/service/TaskScheduleServiceTest.java | 114 ++
hugegraph-pd/local-release.sh | 25 +
hugegraph-pd/mvnw | 308 ++++
hugegraph-pd/mvnw.cmd | 182 ++
hugegraph-pd/pom.xml | 318 ++++
hugegraph-pd/settings.xml | 133 ++
hugegraph-pd/start_pd_server.sh | 55 +
pom.xml | 2 +-
236 files changed, 36208 insertions(+), 1 deletion(-)
create mode 100644 hugegraph-pd/.gitattributes
create mode 100644 hugegraph-pd/.gitignore
create mode 100644 hugegraph-pd/.mvn/wrapper/MavenWrapperDownloader.java
create mode 100644 hugegraph-pd/.mvn/wrapper/maven-wrapper.jar
create mode 100644 hugegraph-pd/.mvn/wrapper/maven-wrapper.properties
create mode 100644 hugegraph-pd/build-pre.sh
create mode 100644 hugegraph-pd/build.sh
create mode 100644 hugegraph-pd/ci.yml
create mode 100644 hugegraph-pd/conf/hugegraph.license
create mode 100644 hugegraph-pd/conf/verify-license.json
create mode 100644 hugegraph-pd/deploy-release.sh
create mode 100644 hugegraph-pd/deploy-snapshot.sh
create mode 100644 hugegraph-pd/hg-pd-client/pom.xml
create mode 100644
hugegraph-pd/hg-pd-client/src/main/java/org/apache/hugegraph/pd/client/AbstractClient.java
create mode 100644
hugegraph-pd/hg-pd-client/src/main/java/org/apache/hugegraph/pd/client/AbstractClientStubProxy.java
create mode 100644
hugegraph-pd/hg-pd-client/src/main/java/org/apache/hugegraph/pd/client/Channels.java
create mode 100644
hugegraph-pd/hg-pd-client/src/main/java/org/apache/hugegraph/pd/client/ClientCache.java
create mode 100644
hugegraph-pd/hg-pd-client/src/main/java/org/apache/hugegraph/pd/client/Discoverable.java
create mode 100644
hugegraph-pd/hg-pd-client/src/main/java/org/apache/hugegraph/pd/client/DiscoveryClient.java
create mode 100644
hugegraph-pd/hg-pd-client/src/main/java/org/apache/hugegraph/pd/client/DiscoveryClientImpl.java
create mode 100644
hugegraph-pd/hg-pd-client/src/main/java/org/apache/hugegraph/pd/client/KvClient.java
create mode 100644
hugegraph-pd/hg-pd-client/src/main/java/org/apache/hugegraph/pd/client/LicenseClient.java
create mode 100644
hugegraph-pd/hg-pd-client/src/main/java/org/apache/hugegraph/pd/client/PDClient.java
create mode 100644
hugegraph-pd/hg-pd-client/src/main/java/org/apache/hugegraph/pd/client/PDConfig.java
create mode 100644
hugegraph-pd/hg-pd-client/src/main/java/org/apache/hugegraph/pd/client/PDPulse.java
create mode 100644
hugegraph-pd/hg-pd-client/src/main/java/org/apache/hugegraph/pd/client/PDPulseImpl.java
create mode 100644
hugegraph-pd/hg-pd-client/src/main/java/org/apache/hugegraph/pd/client/PDWatch.java
create mode 100644
hugegraph-pd/hg-pd-client/src/main/java/org/apache/hugegraph/pd/client/PDWatchImpl.java
create mode 100644
hugegraph-pd/hg-pd-client/src/main/java/org/apache/hugegraph/pd/pulse/PartitionNotice.java
create mode 100644
hugegraph-pd/hg-pd-client/src/main/java/org/apache/hugegraph/pd/pulse/PulseServerNotice.java
create mode 100644
hugegraph-pd/hg-pd-client/src/main/java/org/apache/hugegraph/pd/watch/NodeEvent.java
create mode 100644
hugegraph-pd/hg-pd-client/src/main/java/org/apache/hugegraph/pd/watch/PDWatcher.java
create mode 100644
hugegraph-pd/hg-pd-client/src/main/java/org/apache/hugegraph/pd/watch/PartitionEvent.java
create mode 100644
hugegraph-pd/hg-pd-client/src/main/java/org/apache/hugegraph/pd/watch/WatchType.java
create mode 100644
hugegraph-pd/hg-pd-client/src/test/java/org/apache/hugegraph/pd/PartitionCacheTest.java
create mode 100644
hugegraph-pd/hg-pd-client/src/test/java/org/apache/hugegraph/pd/StoreRegisterTest.java
create mode 100644
hugegraph-pd/hg-pd-client/src/test/java/org/apache/hugegraph/pd/client/DiscoveryClientImplTest.java
create mode 100644
hugegraph-pd/hg-pd-client/src/test/java/org/apache/hugegraph/pd/client/LicenseClientImplTest.java
create mode 100644
hugegraph-pd/hg-pd-client/src/test/java/org/apache/hugegraph/pd/client/PDPulseTest.java
create mode 100644
hugegraph-pd/hg-pd-client/src/test/java/org/apache/hugegraph/pd/client/PDWatchTest.java
create mode 100644
hugegraph-pd/hg-pd-client/src/test/java/org/apache/hugegraph/pd/client/test/HgPDTestUtil.java
create mode 100644 hugegraph-pd/hg-pd-clitools/pom.xml
create mode 100644
hugegraph-pd/hg-pd-clitools/src/main/java/org/apache/hugegraph/pd/clitools/Main.java
create mode 100644
hugegraph-pd/hg-pd-clitools/src/test/java/org/apache/hugegraph/pd/clitools/MainTest.java
create mode 100644 hugegraph-pd/hg-pd-common/pom.xml
create mode 100644
hugegraph-pd/hg-pd-common/src/main/java/org/apache/hugegraph/pd/common/GraphCache.java
create mode 100644
hugegraph-pd/hg-pd-common/src/main/java/org/apache/hugegraph/pd/common/HgAssert.java
create mode 100644
hugegraph-pd/hg-pd-common/src/main/java/org/apache/hugegraph/pd/common/KVPair.java
create mode 100644
hugegraph-pd/hg-pd-common/src/main/java/org/apache/hugegraph/pd/common/PDException.java
create mode 100644
hugegraph-pd/hg-pd-common/src/main/java/org/apache/hugegraph/pd/common/PDRuntimeException.java
create mode 100644
hugegraph-pd/hg-pd-common/src/main/java/org/apache/hugegraph/pd/common/PartitionCache.java
create mode 100644
hugegraph-pd/hg-pd-common/src/main/java/org/apache/hugegraph/pd/common/PartitionUtils.java
create mode 100644 hugegraph-pd/hg-pd-core/pom.xml
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
create mode 100644
hugegraph-pd/hg-pd-core/src/main/java/org/apache/hugegraph/pd/PartitionStatusListener.java
create mode 100644
hugegraph-pd/hg-pd-core/src/main/java/org/apache/hugegraph/pd/RegistryService.java
create mode 100644
hugegraph-pd/hg-pd-core/src/main/java/org/apache/hugegraph/pd/ShardGroupStatusListener.java
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
create mode 100644
hugegraph-pd/hg-pd-core/src/main/java/org/apache/hugegraph/pd/StoreStatusListener.java
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
create mode 100644
hugegraph-pd/hg-pd-core/src/main/java/org/apache/hugegraph/pd/raft/FutureClosureAdapter.java
create mode 100644
hugegraph-pd/hg-pd-core/src/main/java/org/apache/hugegraph/pd/raft/KVOperation.java
create mode 100644
hugegraph-pd/hg-pd-core/src/main/java/org/apache/hugegraph/pd/raft/KVStoreClosure.java
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
create mode 100644
hugegraph-pd/hg-pd-core/src/main/java/org/apache/hugegraph/pd/raft/RaftStateListener.java
create mode 100644
hugegraph-pd/hg-pd-core/src/main/java/org/apache/hugegraph/pd/raft/RaftStateMachine.java
create mode 100644
hugegraph-pd/hg-pd-core/src/main/java/org/apache/hugegraph/pd/raft/RaftTaskHandler.java
create mode 100644
hugegraph-pd/hg-pd-core/src/main/java/org/apache/hugegraph/pd/raft/ZipUtils.java
create mode 100644
hugegraph-pd/hg-pd-core/src/main/java/org/apache/hugegraph/pd/store/BaseKVStoreClosure.java
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
create mode 100644
hugegraph-pd/hg-pd-core/src/main/java/org/apache/hugegraph/pd/store/KV.java
create mode 100644
hugegraph-pd/hg-pd-core/src/main/java/org/apache/hugegraph/pd/store/RaftKVStore.java
create mode 100644
hugegraph-pd/hg-pd-core/src/test/java/org/apache/hugegraph/pd/MonitorServiceTest.java
create mode 100644
hugegraph-pd/hg-pd-core/src/test/java/org/apache/hugegraph/pd/PartitionServiceTest.java
create mode 100644
hugegraph-pd/hg-pd-core/src/test/java/org/apache/hugegraph/pd/StoreNodeServiceTest.java
create mode 100644
hugegraph-pd/hg-pd-core/src/test/java/org/apache/hugegraph/pd/UnitTestBase.java
create mode 100644
hugegraph-pd/hg-pd-core/src/test/java/org/apache/hugegraph/pd/common/PartitionUtilsTest.java
create mode 100644
hugegraph-pd/hg-pd-core/src/test/java/org/apache/hugegraph/pd/store/HgKVStoreImplTest.java
create mode 100644 hugegraph-pd/hg-pd-core/src/test/resources/log4j2.xml
create mode 100644 hugegraph-pd/hg-pd-dist/pom.xml
create mode 100644
hugegraph-pd/hg-pd-dist/src/assembly/descriptor/server-assembly.xml
create mode 100644
hugegraph-pd/hg-pd-dist/src/assembly/static/bin/start-hugegraph-pd.sh
create mode 100644
hugegraph-pd/hg-pd-dist/src/assembly/static/bin/stop-hugegraph-pd.sh
create mode 100644 hugegraph-pd/hg-pd-dist/src/assembly/static/bin/util.sh
create mode 100644
hugegraph-pd/hg-pd-dist/src/assembly/static/conf/application.yml
create mode 100644
hugegraph-pd/hg-pd-dist/src/assembly/static/conf/application.yml.template
create mode 100644
hugegraph-pd/hg-pd-dist/src/assembly/static/conf/hugegraph.license
create mode 100644 hugegraph-pd/hg-pd-dist/src/assembly/static/conf/log4j2.xml
create mode 100644
hugegraph-pd/hg-pd-dist/src/assembly/static/conf/verify-license.json
create mode 100644 hugegraph-pd/hg-pd-grpc/pom.xml
create mode 100644 hugegraph-pd/hg-pd-grpc/src/main/proto/discovery.proto
create mode 100644 hugegraph-pd/hg-pd-grpc/src/main/proto/kv.proto
create mode 100644 hugegraph-pd/hg-pd-grpc/src/main/proto/metaTask.proto
create mode 100644 hugegraph-pd/hg-pd-grpc/src/main/proto/metapb.proto
create mode 100644 hugegraph-pd/hg-pd-grpc/src/main/proto/pd_common.proto
create mode 100644 hugegraph-pd/hg-pd-grpc/src/main/proto/pd_pulse.proto
create mode 100644 hugegraph-pd/hg-pd-grpc/src/main/proto/pd_watch.proto
create mode 100644 hugegraph-pd/hg-pd-grpc/src/main/proto/pdpb.proto
create mode 100644 hugegraph-pd/hg-pd-service/pom.xml
create mode 100644
hugegraph-pd/hg-pd-service/src/main/java/org/apache/hugegraph/pd/boot/HugePDServer.java
create mode 100644
hugegraph-pd/hg-pd-service/src/main/java/org/apache/hugegraph/pd/license/LicenseVerifierService.java
create mode 100644
hugegraph-pd/hg-pd-service/src/main/java/org/apache/hugegraph/pd/license/LicenseVerifyManager.java
create mode 100644
hugegraph-pd/hg-pd-service/src/main/java/org/apache/hugegraph/pd/metrics/MetricsConfig.java
create mode 100644
hugegraph-pd/hg-pd-service/src/main/java/org/apache/hugegraph/pd/metrics/PDMetrics.java
create mode 100644
hugegraph-pd/hg-pd-service/src/main/java/org/apache/hugegraph/pd/model/DemoModel.java
create mode 100644
hugegraph-pd/hg-pd-service/src/main/java/org/apache/hugegraph/pd/model/GraphRestRequest.java
create mode 100644
hugegraph-pd/hg-pd-service/src/main/java/org/apache/hugegraph/pd/model/GraphSpaceRestRequest.java
create mode 100644
hugegraph-pd/hg-pd-service/src/main/java/org/apache/hugegraph/pd/model/PeerRestRequest.java
create mode 100644
hugegraph-pd/hg-pd-service/src/main/java/org/apache/hugegraph/pd/model/PromTargetsModel.java
create mode 100644
hugegraph-pd/hg-pd-service/src/main/java/org/apache/hugegraph/pd/model/RegistryQueryRestRequest.java
create mode 100644
hugegraph-pd/hg-pd-service/src/main/java/org/apache/hugegraph/pd/model/RegistryRestRequest.java
create mode 100644
hugegraph-pd/hg-pd-service/src/main/java/org/apache/hugegraph/pd/model/RegistryRestResponse.java
create mode 100644
hugegraph-pd/hg-pd-service/src/main/java/org/apache/hugegraph/pd/model/RestApiResponse.java
create mode 100644
hugegraph-pd/hg-pd-service/src/main/java/org/apache/hugegraph/pd/model/StoreRestRequest.java
create mode 100644
hugegraph-pd/hg-pd-service/src/main/java/org/apache/hugegraph/pd/model/TimeRangeRequest.java
create mode 100644
hugegraph-pd/hg-pd-service/src/main/java/org/apache/hugegraph/pd/notice/NoticeBroadcaster.java
create mode 100644
hugegraph-pd/hg-pd-service/src/main/java/org/apache/hugegraph/pd/pulse/AbstractObserverSubject.java
create mode 100644
hugegraph-pd/hg-pd-service/src/main/java/org/apache/hugegraph/pd/pulse/PDPulseSubject.java
create mode 100644
hugegraph-pd/hg-pd-service/src/main/java/org/apache/hugegraph/pd/pulse/PartitionHeartbeatSubject.java
create mode 100644
hugegraph-pd/hg-pd-service/src/main/java/org/apache/hugegraph/pd/pulse/PdInstructionSubject.java
create mode 100644
hugegraph-pd/hg-pd-service/src/main/java/org/apache/hugegraph/pd/pulse/PulseListener.java
create mode 100644
hugegraph-pd/hg-pd-service/src/main/java/org/apache/hugegraph/pd/rest/API.java
create mode 100644
hugegraph-pd/hg-pd-service/src/main/java/org/apache/hugegraph/pd/rest/GraphAPI.java
create mode 100644
hugegraph-pd/hg-pd-service/src/main/java/org/apache/hugegraph/pd/rest/GraphSpaceAPI.java
create mode 100644
hugegraph-pd/hg-pd-service/src/main/java/org/apache/hugegraph/pd/rest/IndexAPI.java
create mode 100644
hugegraph-pd/hg-pd-service/src/main/java/org/apache/hugegraph/pd/rest/MemberAPI.java
create mode 100644
hugegraph-pd/hg-pd-service/src/main/java/org/apache/hugegraph/pd/rest/PartitionAPI.java
create mode 100644
hugegraph-pd/hg-pd-service/src/main/java/org/apache/hugegraph/pd/rest/PromTargetsAPI.java
create mode 100644
hugegraph-pd/hg-pd-service/src/main/java/org/apache/hugegraph/pd/rest/RegistryAPI.java
create mode 100644
hugegraph-pd/hg-pd-service/src/main/java/org/apache/hugegraph/pd/rest/ShardAPI.java
create mode 100644
hugegraph-pd/hg-pd-service/src/main/java/org/apache/hugegraph/pd/rest/StoreAPI.java
create mode 100644
hugegraph-pd/hg-pd-service/src/main/java/org/apache/hugegraph/pd/rest/TaskAPI.java
create mode 100644
hugegraph-pd/hg-pd-service/src/main/java/org/apache/hugegraph/pd/rest/TestAPI.java
create mode 100644
hugegraph-pd/hg-pd-service/src/main/java/org/apache/hugegraph/pd/service/DiscoveryService.java
create mode 100644
hugegraph-pd/hg-pd-service/src/main/java/org/apache/hugegraph/pd/service/KvServiceGrpcImpl.java
create mode 100644
hugegraph-pd/hg-pd-service/src/main/java/org/apache/hugegraph/pd/service/PDPulseService.java
create mode 100644
hugegraph-pd/hg-pd-service/src/main/java/org/apache/hugegraph/pd/service/PDRestService.java
create mode 100644
hugegraph-pd/hg-pd-service/src/main/java/org/apache/hugegraph/pd/service/PDService.java
create mode 100644
hugegraph-pd/hg-pd-service/src/main/java/org/apache/hugegraph/pd/service/PDWatchService.java
create mode 100644
hugegraph-pd/hg-pd-service/src/main/java/org/apache/hugegraph/pd/service/PromTargetsService.java
create mode 100644
hugegraph-pd/hg-pd-service/src/main/java/org/apache/hugegraph/pd/service/ServiceGrpc.java
create mode 100644
hugegraph-pd/hg-pd-service/src/main/java/org/apache/hugegraph/pd/service/UpgradeService.java
create mode 100644
hugegraph-pd/hg-pd-service/src/main/java/org/apache/hugegraph/pd/upgrade/VersionScriptFactory.java
create mode 100644
hugegraph-pd/hg-pd-service/src/main/java/org/apache/hugegraph/pd/upgrade/VersionUpgradeScript.java
create mode 100644
hugegraph-pd/hg-pd-service/src/main/java/org/apache/hugegraph/pd/upgrade/scripts/PartitionMetaUpgrade.java
create mode 100644
hugegraph-pd/hg-pd-service/src/main/java/org/apache/hugegraph/pd/upgrade/scripts/TaskCleanUpgrade.java
create mode 100644
hugegraph-pd/hg-pd-service/src/main/java/org/apache/hugegraph/pd/util/DateUtil.java
create mode 100644
hugegraph-pd/hg-pd-service/src/main/java/org/apache/hugegraph/pd/util/HgExecutorUtil.java
create mode 100644
hugegraph-pd/hg-pd-service/src/main/java/org/apache/hugegraph/pd/util/HgMapCache.java
create mode 100644
hugegraph-pd/hg-pd-service/src/main/java/org/apache/hugegraph/pd/util/IdUtil.java
create mode 100644
hugegraph-pd/hg-pd-service/src/main/java/org/apache/hugegraph/pd/util/grpc/GRpcServerConfig.java
create mode 100644
hugegraph-pd/hg-pd-service/src/main/java/org/apache/hugegraph/pd/util/grpc/StreamObserverUtil.java
create mode 100644
hugegraph-pd/hg-pd-service/src/main/java/org/apache/hugegraph/pd/watch/AbstractWatchSubject.java
create mode 100644
hugegraph-pd/hg-pd-service/src/main/java/org/apache/hugegraph/pd/watch/KvWatchSubject.java
create mode 100644
hugegraph-pd/hg-pd-service/src/main/java/org/apache/hugegraph/pd/watch/NodeChangeSubject.java
create mode 100644
hugegraph-pd/hg-pd-service/src/main/java/org/apache/hugegraph/pd/watch/PDWatchSubject.java
create mode 100644
hugegraph-pd/hg-pd-service/src/main/java/org/apache/hugegraph/pd/watch/PartitionChangeSubject.java
create mode 100644
hugegraph-pd/hg-pd-service/src/main/java/org/apache/hugegraph/pd/watch/ShardGroupChangeSubject.java
create mode 100644
hugegraph-pd/hg-pd-service/src/main/resources/application.yml
create mode 100644 hugegraph-pd/hg-pd-service/src/main/resources/banner.txt
create mode 100644 hugegraph-pd/hg-pd-service/src/main/resources/log4j2.xml
create mode 100644 hugegraph-pd/hg-pd-service/src/test/java/live/PDServer0.java
create mode 100644 hugegraph-pd/hg-pd-service/src/test/java/live/PDServer1.java
create mode 100644 hugegraph-pd/hg-pd-service/src/test/java/live/PDServer2.java
create mode 100644 hugegraph-pd/hg-pd-service/src/test/java/live/PDServer3.java
create mode 100644
hugegraph-pd/hg-pd-service/src/test/resources/application-server0.yml
create mode 100644
hugegraph-pd/hg-pd-service/src/test/resources/application-server1.yml
create mode 100644
hugegraph-pd/hg-pd-service/src/test/resources/application-server2.yml
create mode 100644
hugegraph-pd/hg-pd-service/src/test/resources/application-server3.yml
create mode 100644 hugegraph-pd/hg-pd-service/src/test/resources/banner.txt
create mode 100644 hugegraph-pd/hg-pd-service/src/test/resources/log4j2.xml
create mode 100644 hugegraph-pd/hg-pd-test/pom.xml
create mode 100644
hugegraph-pd/hg-pd-test/src/main/java/org/apache/hugegraph/pd/client/BaseClientTest.java
create mode 100644
hugegraph-pd/hg-pd-test/src/main/java/org/apache/hugegraph/pd/client/DiscoveryClientTest.java
create mode 100644
hugegraph-pd/hg-pd-test/src/main/java/org/apache/hugegraph/pd/client/KvClientTest.java
create mode 100644
hugegraph-pd/hg-pd-test/src/main/java/org/apache/hugegraph/pd/client/PDClientSuiteTest.java
create mode 100644
hugegraph-pd/hg-pd-test/src/main/java/org/apache/hugegraph/pd/client/PDClientTest.java
create mode 100644
hugegraph-pd/hg-pd-test/src/main/java/org/apache/hugegraph/pd/clitools/BaseCliToolsTest.java
create mode 100644
hugegraph-pd/hg-pd-test/src/main/java/org/apache/hugegraph/pd/clitools/CliToolsSuiteTest.java
create mode 100644
hugegraph-pd/hg-pd-test/src/main/java/org/apache/hugegraph/pd/clitools/MainTest.java
create mode 100644
hugegraph-pd/hg-pd-test/src/main/java/org/apache/hugegraph/pd/common/BaseCommonTest.java
create mode 100644
hugegraph-pd/hg-pd-test/src/main/java/org/apache/hugegraph/pd/common/CommonSuiteTest.java
create mode 100644
hugegraph-pd/hg-pd-test/src/main/java/org/apache/hugegraph/pd/common/HgAssertTest.java
create mode 100644
hugegraph-pd/hg-pd-test/src/main/java/org/apache/hugegraph/pd/common/KVPairTest.java
create mode 100644
hugegraph-pd/hg-pd-test/src/main/java/org/apache/hugegraph/pd/common/MetadataKeyHelperTest.java
create mode 100644
hugegraph-pd/hg-pd-test/src/main/java/org/apache/hugegraph/pd/common/PartitionCacheTest.java
create mode 100644
hugegraph-pd/hg-pd-test/src/main/java/org/apache/hugegraph/pd/common/PartitionUtilsTest.java
create mode 100644
hugegraph-pd/hg-pd-test/src/main/java/org/apache/hugegraph/pd/core/BaseCoreTest.java
create mode 100644
hugegraph-pd/hg-pd-test/src/main/java/org/apache/hugegraph/pd/core/PDCoreSuiteTest.java
create mode 100644
hugegraph-pd/hg-pd-test/src/main/java/org/apache/hugegraph/pd/core/StoreNodeServiceTest.java
create mode 100644
hugegraph-pd/hg-pd-test/src/main/java/org/apache/hugegraph/pd/core/meta/MetadataKeyHelperTest.java
create mode 100644
hugegraph-pd/hg-pd-test/src/main/java/org/apache/hugegraph/pd/grpc/BaseGrpcTest.java
create mode 100644
hugegraph-pd/hg-pd-test/src/main/java/org/apache/hugegraph/pd/grpc/GrpcSuiteTest.java
create mode 100644
hugegraph-pd/hg-pd-test/src/main/java/org/apache/hugegraph/pd/service/BaseServerTest.java
create mode 100644
hugegraph-pd/hg-pd-test/src/main/java/org/apache/hugegraph/pd/service/ConfigServiceTest.java
create mode 100644
hugegraph-pd/hg-pd-test/src/main/java/org/apache/hugegraph/pd/service/IdServiceTest.java
create mode 100644
hugegraph-pd/hg-pd-test/src/main/java/org/apache/hugegraph/pd/service/KvServiceTest.java
create mode 100644
hugegraph-pd/hg-pd-test/src/main/java/org/apache/hugegraph/pd/service/LogServiceTest.java
create mode 100644
hugegraph-pd/hg-pd-test/src/main/java/org/apache/hugegraph/pd/service/PartitionServiceTest.java
create mode 100644
hugegraph-pd/hg-pd-test/src/main/java/org/apache/hugegraph/pd/service/PdTestBase.java
create mode 100644
hugegraph-pd/hg-pd-test/src/main/java/org/apache/hugegraph/pd/service/RestApiTest.java
create mode 100644
hugegraph-pd/hg-pd-test/src/main/java/org/apache/hugegraph/pd/service/ServerSuiteTest.java
create mode 100644
hugegraph-pd/hg-pd-test/src/main/java/org/apache/hugegraph/pd/service/StoreMonitorDataServiceTest.java
create mode 100644
hugegraph-pd/hg-pd-test/src/main/java/org/apache/hugegraph/pd/service/StoreNodeServiceNewTest.java
create mode 100644
hugegraph-pd/hg-pd-test/src/main/java/org/apache/hugegraph/pd/service/StoreServiceTest.java
create mode 100644
hugegraph-pd/hg-pd-test/src/main/java/org/apache/hugegraph/pd/service/TaskScheduleServiceTest.java
create mode 100755 hugegraph-pd/local-release.sh
create mode 100644 hugegraph-pd/mvnw
create mode 100644 hugegraph-pd/mvnw.cmd
create mode 100644 hugegraph-pd/pom.xml
create mode 100644 hugegraph-pd/settings.xml
create mode 100644 hugegraph-pd/start_pd_server.sh
