This is an automated email from the ASF dual-hosted git repository. jin pushed a commit to branch pd-store in repository https://gitbox.apache.org/repos/asf/incubator-hugegraph.git
commit 7e9b8afbc69c007592805a58a4bcfcb4e3b53d5a Merge: 4f34d01eb c72bda623 Author: imbajin <[email protected]> AuthorDate: Tue Aug 8 17:19:34 2023 +0800 refact(store): merge branch 'pr/2272' into pd-store hugegraph-store/.gitattributes | 1 + hugegraph-store/.gitignore | 53 + .../.mvn/wrapper/MavenWrapperDownloader.java | 120 ++ .../.mvn/wrapper/maven-wrapper.properties | 18 + hugegraph-store/LICENSE | 216 ++++ hugegraph-store/NOTICE | 7 + hugegraph-store/README-dev.md | 43 + hugegraph-store/README.md | 579 +++++++++ hugegraph-store/build-change.sh | 35 + hugegraph-store/build-pre.sh | 105 ++ hugegraph-store/build.sh | 33 + hugegraph-store/ci.yml | 43 + hugegraph-store/conf/application-pd.yml | 17 + hugegraph-store/deploy-release.sh | 25 + hugegraph-store/deploy-snapshot.sh | 23 + hugegraph-store/hg-store-cli/deploy-snapshot.sh | 22 + hugegraph-store/hg-store-cli/pom.xml | 82 ++ .../org/apache/hugegraph/store/cli/AppConfig.java | 55 + .../store/cli/StoreConsoleApplication.java | 118 ++ .../hugegraph/store/cli/loader/HgThread2DB.java | 587 +++++++++ .../hugegraph/store/cli/scan/GrpcShardScanner.java | 166 +++ .../hugegraph/store/cli/scan/HgStoreCommitter.java | 87 ++ .../hugegraph/store/cli/scan/HgStoreScanner.java | 237 ++++ .../apache/hugegraph/store/cli/util/HgCliUtil.java | 259 ++++ .../apache/hugegraph/store/cli/util/HgMetricX.java | 61 + .../src/main/resources/application.yml | 40 + .../src/main/resources/hg-store-client.properties | 23 + .../hg-store-cli/src/main/resources/log4j2.xml | 77 ++ hugegraph-store/hg-store-client/deploy-snapshot.sh | 23 + hugegraph-store/hg-store-client/pom.xml | 107 ++ .../java/org/apache/hugegraph/store/HgKvEntry.java | 29 + .../org/apache/hugegraph/store/HgKvIterator.java | 35 + .../hugegraph/store/HgKvOrderedIterator.java | 25 + .../apache/hugegraph/store/HgKvPagingIterator.java | 24 + .../java/org/apache/hugegraph/store/HgKvStore.java | 125 ++ .../org/apache/hugegraph/store/HgOwnerKey.java | 149 +++ .../org/apache/hugegraph/store/HgPageSize.java | 31 + .../java/org/apache/hugegraph/store/HgPrivate.java | 32 + .../org/apache/hugegraph/store/HgScanQuery.java | 332 +++++ .../org/apache/hugegraph/store/HgSeekAble.java | 27 + .../apache/hugegraph/store/HgSessionManager.java | 55 + .../apache/hugegraph/store/HgSessionProvider.java | 28 + .../org/apache/hugegraph/store/HgStoreClient.java | 96 ++ .../org/apache/hugegraph/store/HgStoreSession.java | 40 + .../org/apache/hugegraph/store/HgTkvEntry.java | 27 + .../org/apache/hugegraph/store/HgTokvEntry.java | 27 + .../hugegraph/store/client/HgNodePartition.java | 102 ++ .../store/client/HgNodePartitionerBuilder.java | 70 ++ .../apache/hugegraph/store/client/HgPrivate.java | 34 + .../apache/hugegraph/store/client/HgStoreNode.java | 60 + .../hugegraph/store/client/HgStoreNodeBuilder.java | 36 + .../store/client/HgStoreNodeCandidates.java | 41 + .../hugegraph/store/client/HgStoreNodeManager.java | 264 ++++ .../store/client/HgStoreNodeNotifier.java | 36 + .../store/client/HgStoreNodePartitioner.java | 66 + .../store/client/HgStoreNodePartitionerImpl.java | 200 +++ .../store/client/HgStoreNodeProvider.java | 34 + .../hugegraph/store/client/HgStoreNodeSession.java | 44 + .../hugegraph/store/client/HgStoreNotice.java | 99 ++ .../hugegraph/store/client/HgStoreService.java | 32 + .../store/client/HgStoreSessionProvider.java | 36 + .../hugegraph/store/client/HgTkvEntryImpl.java | 83 ++ .../hugegraph/store/client/HgTokvEntryImpl.java | 84 ++ .../store/client/MultiNodeSessionFactory.java | 53 + .../org/apache/hugegraph/store/client/NodeTkv.java | 124 ++ .../hugegraph/store/client/NodeTxExecutor.java | 434 +++++++ .../hugegraph/store/client/NodeTxSessionProxy.java | 890 ++++++++++++++ .../hugegraph/store/client/SequencedIterator.java | 148 +++ .../store/client/ShiftWorkIteratorProxy.java | 162 +++ .../store/client/TopWorkIteratorProxy.java | 146 +++ .../store/client/grpc/AbstractGrpcClient.java | 176 +++ .../store/client/grpc/GrpcKvEntryImpl.java | 78 ++ .../store/client/grpc/GrpcKvIteratorImpl.java | 162 +++ .../store/client/grpc/GrpcNodeHealthyClient.java | 92 ++ .../store/client/grpc/GrpcStoreNodeBuilder.java | 77 ++ .../store/client/grpc/GrpcStoreNodeImpl.java | 97 ++ .../client/grpc/GrpcStoreNodeSessionImpl.java | 546 +++++++++ .../store/client/grpc/GrpcStoreSessionClient.java | 160 +++ .../store/client/grpc/GrpcStoreStateClient.java | 77 ++ .../store/client/grpc/GrpcStoreStreamClient.java | 219 ++++ .../hugegraph/store/client/grpc/GrpcUtil.java | 149 +++ .../store/client/grpc/KvBatchOneShotScanner.java | 123 ++ .../store/client/grpc/KvBatchScanner.java | 406 +++++++ .../store/client/grpc/KvBatchScanner5.java | 450 +++++++ .../store/client/grpc/KvBatchScannerMerger.java | 333 +++++ .../hugegraph/store/client/grpc/KvBatchUtil.java | 155 +++ .../store/client/grpc/KvCloseableIterator.java | 29 + .../store/client/grpc/KvListIterator.java | 48 + .../store/client/grpc/KvOneShotScanner.java | 212 ++++ .../hugegraph/store/client/grpc/KvPageScanner.java | 310 +++++ .../store/client/grpc/NotifyingExecutor.java | 254 ++++ .../hugegraph/store/client/grpc/ScanUtil.java | 53 + .../store/client/grpc/SeekAbleIterator.java | 69 ++ .../store/client/grpc/SwitchingExecutor.java | 53 + .../hugegraph/store/client/type/HgNodeStatus.java | 45 + .../store/client/type/HgStoreClientException.java | 48 + .../apache/hugegraph/store/client/util/Base58.java | 172 +++ .../hugegraph/store/client/util/ExecutorPool.java | 62 + .../hugegraph/store/client/util/HgAssert.java | 134 +++ .../hugegraph/store/client/util/HgBufferProxy.java | 161 +++ .../store/client/util/HgStoreClientConfig.java | 191 +++ .../store/client/util/HgStoreClientConst.java | 51 + .../store/client/util/HgStoreClientUtil.java | 174 +++ .../apache/hugegraph/store/client/util/HgUuid.java | 42 + .../hugegraph/store/client/util/MetricX.java | 105 ++ .../hugegraph/store/client/util/PropertyUtil.java | 98 ++ .../src/main/resources/hg-store-client.properties | 22 + .../hg-store-client/src/main/resources/log4j2.xml | 102 ++ .../store/HgSessionManagerOneRaftFakePDTest.java | 481 ++++++++ .../store/HgSessionManagerRaftFakePDTest.java | 648 ++++++++++ .../store/HgSessionManagerRaftPDTest.java | 981 +++++++++++++++ .../hugegraph/store/HgSessionManagerTest.java | 1125 +++++++++++++++++ .../hugegraph/store/client/HgKvStoreTest.java | 225 ++++ .../hugegraph/store/client/HgStoreClientBase.java | 42 + .../hugegraph/store/client/HgStoreClientTest.java | 210 ++++ .../store/client/HgStoreNodeSessionTest.java | 70 ++ .../store/client/HgStoreNodeStateTest.java | 70 ++ .../store/client/HgStoreNodeStreamTest.java | 185 +++ .../apache/hugegraph/store/common/BitsTest.java | 34 + .../hugegraph/store/test/ChangeShardNumTest.java | 69 ++ .../hugegraph/store/util/HgStoreTestUtil.java | 462 +++++++ .../hg-store-client/src/test/resources/log4j2.xml | 102 ++ .../src/test/resources/pd-server.yml | 71 ++ .../.mvn/wrapper/MavenWrapperDownloader.java | 121 ++ .../.mvn/wrapper/maven-wrapper.properties | 18 + hugegraph-store/hg-store-common/mvnw | 310 +++++ hugegraph-store/hg-store-common/mvnw.cmd | 182 +++ hugegraph-store/hg-store-common/pom.xml | 33 + .../store/buffer/ByteBufferAllocator.java | 64 + .../hugegraph/store/buffer/KVByteBuffer.java | 97 ++ .../java/org/apache/hugegraph/store/term/Bits.java | 65 + .../org/apache/hugegraph/store/term/HgPair.java | 142 +++ .../org/apache/hugegraph/store/term/HgTriple.java | 78 ++ hugegraph-store/hg-store-core/build.sh | 32 + hugegraph-store/hg-store-core/pom.xml | 134 +++ .../apache/hugegraph/store/HeartbeatService.java | 386 ++++++ .../org/apache/hugegraph/store/HgStoreEngine.java | 729 +++++++++++ .../hugegraph/store/HgStoreStateListener.java | 25 + .../apache/hugegraph/store/PartitionEngine.java | 1267 ++++++++++++++++++++ .../store/PartitionInstructionProcessor.java | 344 ++++++ .../hugegraph/store/PartitionStateListener.java | 33 + .../store/business/AbstractSelectIterator.java | 66 + .../hugegraph/store/business/BusinessHandler.java | 216 ++++ .../store/business/BusinessHandlerImpl.java | 925 ++++++++++++++ .../apache/hugegraph/store/business/DataMover.java | 76 ++ .../hugegraph/store/business/DefaultDataMover.java | 278 +++++ .../hugegraph/store/business/FilterIterator.java | 126 ++ .../store/business/GraphStoreIterator.java | 351 ++++++ .../hugegraph/store/business/InnerKeyCreator.java | 119 ++ .../hugegraph/store/business/InnerKeyFilter.java | 104 ++ .../store/business/MultiPartitionIterator.java | 200 +++ .../hugegraph/store/business/SelectIterator.java | 107 ++ .../hugegraph/store/cmd/BatchPutRequest.java | 50 + .../hugegraph/store/cmd/BatchPutResponse.java | 21 + .../hugegraph/store/cmd/CleanDataRequest.java | 71 ++ .../hugegraph/store/cmd/CleanDataResponse.java | 21 + .../hugegraph/store/cmd/CreateRaftRequest.java | 71 ++ .../hugegraph/store/cmd/CreateRaftResponse.java | 21 + .../hugegraph/store/cmd/DbCompactionRequest.java | 31 + .../hugegraph/store/cmd/DbCompactionResponse.java | 21 + .../hugegraph/store/cmd/DestroyRaftRequest.java | 37 + .../hugegraph/store/cmd/DestroyRaftResponse.java | 22 + .../hugegraph/store/cmd/FutureClosureAdapter.java | 48 + .../hugegraph/store/cmd/GetStoreInfoRequest.java | 25 + .../hugegraph/store/cmd/GetStoreInfoResponse.java | 43 + .../org/apache/hugegraph/store/cmd/HgCmdBase.java | 75 ++ .../apache/hugegraph/store/cmd/HgCmdClient.java | 260 ++++ .../apache/hugegraph/store/cmd/HgCmdProcessor.java | 227 ++++ .../store/cmd/UpdatePartitionRequest.java | 36 + .../store/cmd/UpdatePartitionResponse.java | 21 + .../hugegraph/store/meta/DeletedFileManager.java | 66 + .../org/apache/hugegraph/store/meta/Graph.java | 62 + .../hugegraph/store/meta/GraphIdManager.java | 181 +++ .../apache/hugegraph/store/meta/GraphManager.java | 85 ++ .../hugegraph/store/meta/MetadataKeyHelper.java | 315 +++++ .../org/apache/hugegraph/store/meta/Partition.java | 94 ++ .../hugegraph/store/meta/PartitionManager.java | 925 ++++++++++++++ .../apache/hugegraph/store/meta/PartitionRole.java | 77 ++ .../hugegraph/store/meta/PartitionStats.java | 58 + .../org/apache/hugegraph/store/meta/Shard.java | 42 + .../apache/hugegraph/store/meta/ShardGroup.java | 114 ++ .../org/apache/hugegraph/store/meta/Store.java | 96 ++ .../apache/hugegraph/store/meta/StoreMetadata.java | 230 ++++ .../apache/hugegraph/store/meta/TaskManager.java | 147 +++ .../store/meta/asynctask/AbstractAsyncTask.java | 145 +++ .../hugegraph/store/meta/asynctask/AsyncTask.java | 55 + .../store/meta/asynctask/AsyncTaskState.java | 24 + .../hugegraph/store/meta/asynctask/CleanTask.java | 75 ++ .../store/meta/base/DBSessionBuilder.java | 25 + .../hugegraph/store/meta/base/GlobalMetaStore.java | 57 + .../hugegraph/store/meta/base/MetaStoreBase.java | 173 +++ .../store/meta/base/PartitionMetaStore.java | 51 + .../hugegraph/store/metric/HgMetricService.java | 198 +++ .../hugegraph/store/metric/HgStoreMetric.java | 44 + .../store/metric/SystemMetricService.java | 448 +++++++ .../store/options/HgStoreEngineOptions.java | 146 +++ .../hugegraph/store/options/MetadataOptions.java | 26 + .../store/options/PartitionEngineOptions.java | 47 + .../store/options/RaftRocksdbOptions.java | 207 ++++ .../hugegraph/store/pd/DefaultPdProvider.java | 474 ++++++++ .../hugegraph/store/pd/FakePdServiceProvider.java | 265 ++++ .../store/pd/PartitionInstructionListener.java | 54 + .../org/apache/hugegraph/store/pd/PdProvider.java | 92 ++ .../hugegraph/store/raft/HgStoreStateMachine.java | 269 +++++ .../apache/hugegraph/store/raft/RaftClosure.java | 26 + .../apache/hugegraph/store/raft/RaftOperation.java | 127 ++ .../hugegraph/store/raft/RaftStateListener.java | 87 ++ .../hugegraph/store/raft/RaftTaskHandler.java | 31 + .../hugegraph/store/raft/util/RaftUtils.java | 87 ++ .../store/snapshot/HgSnapshotHandler.java | 225 ++++ .../org/apache/hugegraph/store/util/Asserts.java | 63 + .../hugegraph/store/util/CopyOnWriteCache.java | 150 +++ .../apache/hugegraph/store/util/FutureClosure.java | 93 ++ .../apache/hugegraph/store/util/HgRaftError.java | 70 ++ .../apache/hugegraph/store/util/HgStoreConst.java | 36 + .../hugegraph/store/util/HgStoreException.java | 79 ++ .../org/apache/hugegraph/store/util/IpUtil.java | 100 ++ .../org/apache/hugegraph/store/util/Lifecycle.java | 33 + .../hugegraph/store/util/ManualResetEvent.java | 95 ++ .../store/util/PartitionMetaStoreWrapper.java | 74 ++ .../hugegraph/store/util/UnsafeUtf8Util.java | 328 +++++ .../apache/hugegraph/store/util/UnsafeUtil.java | 331 +++++ .../org/apache/hugegraph/store/util/Version.java | 51 + .../org/apache/hugegraph/store/util/ZipUtils.java | 94 ++ .../apache/hugegraph/store/HgBusinessImplTest.java | 210 ++++ .../hugegraph/store/PartitionEngineTest.java | 236 ++++ .../org/apache/hugegraph/store/UnitTestBase.java | 99 ++ .../hugegraph/store/meta/GraphIDManagerTest.java | 85 ++ .../hugegraph/store/meta/GraphManagerTest.java | 45 + .../hugegraph/store/util/CopyOnWriteCacheTest.java | 65 + .../hugegraph/store/util/FutureClosureTest.java | 43 + .../hg-store-core/src/test/resources/log4j2.xml | 101 ++ .../hg-store-core/src/test/resources/version.txt | 1 + hugegraph-store/hg-store-dist/pom.xml | 152 +++ hugegraph-store/hg-store-dist/release-docs/LICENSE | 216 ++++ hugegraph-store/hg-store-dist/release-docs/NOTICE | 7 + .../src/assembly/descriptor/server-assembly.xml | 59 + .../src/assembly/static/bin/libjemalloc.so | Bin 0 -> 5956008 bytes .../src/assembly/static/bin/libjemalloc_aarch64.so | Bin 0 -> 6023520 bytes .../assembly/static/bin/restart-hugegraph-store.sh | 32 + .../assembly/static/bin/start-hugegraph-store.sh | 166 +++ .../assembly/static/bin/stop-hugegraph-store.sh | 49 + .../hg-store-dist/src/assembly/static/bin/util.sh | 372 ++++++ .../src/assembly/static/conf/application-pd.yml | 17 + .../src/assembly/static/conf/application.yml | 64 + .../src/assembly/static/conf/log4j2.xml | 136 +++ hugegraph-store/hg-store-grpc/.gitignore | 1 + hugegraph-store/hg-store-grpc/build.sh | 26 + hugegraph-store/hg-store-grpc/pom.xml | 162 +++ .../store/grpc/stream/HgStoreStreamGrpc.java | 560 +++++++++ .../store/grpc/stream/HgStoreStreamProto.java | 78 ++ .../hugegraph/store/grpc/stream/KvStream.java | 910 ++++++++++++++ .../store/grpc/stream/KvStreamOrBuilder.java | 70 ++ .../hugegraph/store/grpc/stream/store_stream.proto | 33 + .../hg-store-grpc/src/main/proto/graphpb.proto | 121 ++ .../hg-store-grpc/src/main/proto/healthy.proto | 13 + .../src/main/proto/store_common.proto | 96 ++ .../src/main/proto/store_session.proto | 121 ++ .../hg-store-grpc/src/main/proto/store_state.proto | 56 + .../src/main/proto/store_stream_meta.proto | 92 ++ hugegraph-store/hg-store-node/banner.txt | 5 + hugegraph-store/hg-store-node/pom.xml | 179 +++ .../hg-store-node/src/assembly/static/bin/app.sh | 72 ++ .../src/assembly/static/bin/hg-get-release.sh | 72 ++ .../src/assembly/static/bin/hg-update.sh | 48 + .../org/apache/hugegraph/store/node/AppConfig.java | 228 ++++ .../hugegraph/store/node/AppShutdownHook.java | 59 + .../hugegraph/store/node/StoreNodeApplication.java | 65 + .../node/controller/HgStoreMetricsController.java | 66 + .../node/controller/HgStoreStatusController.java | 94 ++ .../store/node/controller/HgTestController.java | 116 ++ .../hugegraph/store/node/controller/IndexAPI.java | 105 ++ .../store/node/controller/PartitionAPI.java | 248 ++++ .../hugegraph/store/node/entry/RestResult.java | 31 + .../store/node/grpc/BatchGrpcClosure.java | 212 ++++ .../store/node/grpc/BatchScanIterator.java | 160 +++ .../hugegraph/store/node/grpc/EmptyIterator.java | 56 + .../store/node/grpc/FusingScanIterator.java | 120 ++ .../store/node/grpc/GRpcServerConfig.java | 46 + .../hugegraph/store/node/grpc/GrpcClosure.java | 72 ++ .../store/node/grpc/HgStoreNodeService.java | 237 ++++ .../store/node/grpc/HgStoreNodeState.java | 57 + .../store/node/grpc/HgStoreSessionImpl.java | 551 +++++++++ .../store/node/grpc/HgStoreStateService.java | 59 + .../store/node/grpc/HgStoreStateSubject.java | 73 ++ .../store/node/grpc/HgStoreStreamImpl.java | 121 ++ .../store/node/grpc/HgStoreWrapperEx.java | 123 ++ .../store/node/grpc/ParallelScanIterator.java | 386 ++++++ .../hugegraph/store/node/grpc/QueryCondition.java | 39 + .../store/node/grpc/ScanBatchOneShotResponse.java | 105 ++ .../store/node/grpc/ScanBatchResponse.java | 278 +++++ .../store/node/grpc/ScanBatchResponse3.java | 417 +++++++ .../store/node/grpc/ScanBatchResponseFactory.java | 63 + .../store/node/grpc/ScanOneShotResponse.java | 96 ++ .../hugegraph/store/node/grpc/ScanQuery.java | 104 ++ .../store/node/grpc/ScanQueryProducer.java | 262 ++++ .../store/node/grpc/ScanStreamResponse.java | 261 ++++ .../apache/hugegraph/store/node/grpc/ScanUtil.java | 331 +++++ .../store/node/grpc/scan/GraphStoreImpl.java | 84 ++ .../store/node/grpc/scan/ScanResponseObserver.java | 267 +++++ .../store/node/listener/ContextClosedListener.java | 53 + .../store/node/listener/PdConfigureListener.java | 212 ++++ .../hugegraph/store/node/metrics/DriveMetrics.java | 58 + .../store/node/metrics/GRpcExMetrics.java | 94 ++ .../hugegraph/store/node/metrics/JRaftMetrics.java | 314 +++++ .../store/node/metrics/MetricsConfig.java | 48 + .../hugegraph/store/node/metrics/MetricsUtil.java | 52 + .../hugegraph/store/node/metrics/ProcfsEntry.java | 63 + .../store/node/metrics/ProcfsMetrics.java | 67 ++ .../hugegraph/store/node/metrics/ProcfsReader.java | 141 +++ .../hugegraph/store/node/metrics/ProcfsSmaps.java | 113 ++ .../store/node/metrics/RocksDBMetrics.java | 419 +++++++ .../store/node/metrics/RocksDBMetricsConst.java | 165 +++ .../hugegraph/store/node/metrics/StoreMetrics.java | 112 ++ .../store/node/metrics/SystemMetrics.java | 140 +++ .../hugegraph/store/node/model/HgNodeStatus.java | 76 ++ .../apache/hugegraph/store/node/util/Base58.java | 172 +++ .../org/apache/hugegraph/store/node/util/Err.java | 38 + .../apache/hugegraph/store/node/util/HgAssert.java | 145 +++ .../hugegraph/store/node/util/HgBufferProxy.java | 175 +++ .../hugegraph/store/node/util/HgChannel.java | 151 +++ .../hugegraph/store/node/util/HgExecutorUtil.java | 98 ++ .../apache/hugegraph/store/node/util/HgGrpc.java | 122 ++ .../hugegraph/store/node/util/HgRegexUtil.java | 92 ++ .../hugegraph/store/node/util/HgStoreConst.java | 39 + .../hugegraph/store/node/util/HgStoreNodeUtil.java | 83 ++ .../hugegraph/store/node/util/PropertyUtil.java | 96 ++ .../apache/hugegraph/store/node/util/Result.java | 43 + .../apache/hugegraph/store/node/util/TkEntry.java | 69 ++ .../src/main/resources/application-pd.yml | 38 + .../src/main/resources/application.yml | 51 + .../hg-store-node/src/main/resources/banner.txt | 6 + .../src/main/resources/log4j2-dev.xml | 143 +++ .../hg-store-node/src/main/resources/version.txt | 1 + .../hugegraph/store/boot/StoreNodeServer00.java | 57 + .../hugegraph/store/boot/StoreNodeServer01.java | 59 + .../hugegraph/store/boot/StoreNodeServer02.java | 57 + .../hugegraph/store/boot/StoreNodeServer03.java | 57 + .../hugegraph/store/boot/StoreNodeServer04.java | 41 + .../hugegraph/store/boot/StoreNodeServer05.java | 41 + .../hugegraph/store/boot/StoreNodeServer06.java | 41 + .../store/node/HgStoreNodeServiceTest.java | 73 ++ .../store/node/metrics/JraftMetricsTest.java | 59 + .../src/test/resources/application-pd.yml | 28 + .../src/test/resources/application-server00.yml | 73 ++ .../src/test/resources/application-server01.yml | 70 ++ .../src/test/resources/application-server02.yml | 69 ++ .../src/test/resources/application-server03.yml | 71 ++ .../src/test/resources/application-server04.yml | 68 ++ .../src/test/resources/application-server05.yml | 70 ++ .../src/test/resources/application-server06.yml | 70 ++ .../src/test/resources/log4j2-dev.xml | 139 +++ hugegraph-store/hg-store-rocksdb/pom.xml | 79 ++ .../hugegraph/rocksdb/access/DBSnapshotMeta.java | 55 + .../hugegraph/rocksdb/access/DBStoreException.java | 63 + .../hugegraph/rocksdb/access/RocksDBFactory.java | 317 +++++ .../hugegraph/rocksdb/access/RocksDBOptions.java | 429 +++++++ .../rocksdb/access/RocksDBScanIterator.java | 236 ++++ .../hugegraph/rocksdb/access/RocksDBSession.java | 1057 ++++++++++++++++ .../hugegraph/rocksdb/access/ScanIterator.java | 55 + .../hugegraph/rocksdb/access/SessionOperator.java | 78 ++ .../rocksdb/access/SessionOperatorImpl.java | 418 +++++++ .../hugegraph/rocksdb/access/util/Asserts.java | 43 + .../hugegraph/rocksdb/access/util/CRC64.java | 187 +++ .../hugegraph/rocksdb/access/util/ZipUtils.java | 129 ++ .../src/main/java/place-holder.txt} | 0 .../rocksdb/access/RocksDBFactoryTest.java | 102 ++ .../rocksdb/access/RocksDBSessionTest.java | 480 ++++++++ .../hugegraph/rocksdb/access/RocksdbDump.java | 66 + .../rocksdb/access/SnapshotManagerTest.java | 431 +++++++ .../src/test/java/place-holder.txt} | 0 .../src/test/resources/hugegraph-2.properties | 31 + .../src/test/resources/hugegraph.properties | 31 + .../hg-store-rocksdb/src/test/resources/log4j2.xml | 30 + hugegraph-store/hg-store-test/pom.xml | 347 ++++++ .../src/main/java/client/BaseClientTest.java | 48 + .../src/main/java/client/ChangeShardNumTest.java | 67 ++ .../src/main/java/client/ClientSuiteTest.java | 41 + .../src/main/java/client/ClientTest.java | 34 + .../src/main/java/client/HgAssertTest.java | 169 +++ .../src/main/java/client/HgKvStoreTest.java | 191 +++ .../src/main/java/client/HgPairTest.java | 78 ++ .../java/client/HgSessionManagerRaftPDTest.java | 699 +++++++++++ .../src/main/java/client/HgStoreClientTest.java | 211 ++++ .../src/main/java/client/HgStoreNodeStateTest.java | 61 + .../java/client/graph/GraphStoreClientTest.java | 182 +++ .../src/main/java/common/BaseCommonTest.java | 32 + .../main/java/common/ByteBufferAllocatorTest.java | 66 + .../src/main/java/common/CommonSuiteTest.java | 33 + .../src/main/java/common/KVByteBufferTest.java | 68 ++ .../src/main/java/core/BaseCoreTest.java | 46 + .../src/main/java/core/CoreSuiteTest.java | 67 ++ .../hg-store-test/src/main/java/core/CoreTest.java | 34 + .../src/main/java/core/HgBusinessImplTest.java | 178 +++ .../src/main/java/core/HgCmdClientTest.java | 357 ++++++ .../src/main/java/core/MetricServiceTest.java | 63 + .../src/main/java/core/StoreEngineTestBase.java | 135 +++ .../java/core/raft/HgStoreStateMachineTest.java | 245 ++++ .../src/main/java/core/raft/MockStateMachine.java | 30 + .../src/main/java/core/raft/RaftOperationTest.java | 72 ++ .../src/main/java/core/raft/RaftUtilsTest.java | 180 +++ .../java/core/snapshot/HgSnapshotHandlerTest.java | 188 +++ .../main/java/core/store/HgStoreEngineTest.java | 175 +++ .../main/java/core/store/PartitionEngineTest.java | 94 ++ .../store/PartitionInstructionProcessorTest.java | 110 ++ .../core/store/meta/MetadataKeyHelperTest.java | 34 + .../java/core/store/meta/PartitionManagerTest.java | 198 +++ .../main/java/core/store/meta/TaskManagerTest.java | 109 ++ .../core/store/meta/asynctask/CleanTaskTest.java | 49 + .../java/core/store/util/MiscUtilClassTest.java | 93 ++ .../store/util/PartitionMetaStoreWrapperTest.java | 88 ++ .../main/java/core/store/util/ZipUtilsTest.java | 53 + .../src/main/java/raftcore/BytesCarrierTest.java | 62 + .../src/main/java/raftcore/RaftSuiteTest.java | 30 + .../java/raftcore/ZeroByteStringHelperTest.java | 68 ++ .../src/main/java/rocksdb/BaseRocksDbTest.java | 51 + .../src/main/java/rocksdb/RocksDBFactoryTest.java | 81 ++ .../src/main/java/rocksdb/RocksDbSuiteTest.java | 32 + .../src/main/java/service/BaseServerTest.java | 33 + .../src/main/java/service/ServerSuiteTest.java | 32 + .../src/main/java/service/SessionTest.java | 30 + .../src/main/java/util/CopyOnWriteCacheTest.java | 65 + .../src/main/java/util/HgStoreTestUtil.java | 480 ++++++++ .../src/main/java/util/UnitTestBase.java | 98 ++ .../src/main/java/util/UnsafeUtilTest.java | 175 +++ .../hg-store-test/src/main/resources/version.txt | 1 + hugegraph-store/init.sh | 25 + hugegraph-store/local-release.sh | 25 + hugegraph-store/lombok.config | 19 + hugegraph-store/mvnw | 310 +++++ hugegraph-store/mvnw.cmd | 182 +++ hugegraph-store/pom.xml | 338 ++++++ hugegraph-store/run.sh | 22 + hugegraph-store/settings.xml | 133 ++ hugegraph-store/start_server.sh | 55 + pom.xml | 3 +- 436 files changed, 60292 insertions(+), 2 deletions(-)
