This is an automated email from the ASF dual-hosted git repository. yangjiaqi pushed a commit to branch pd-store-jacky in repository https://gitbox.apache.org/repos/asf/incubator-hugegraph.git
commit d0d8972dccd3527285891bdd34a88f8e56a894eb Merge: 5809687cf 198f7004a Author: jacky.yang <[email protected]> AuthorDate: Tue Feb 27 14:40:28 2024 +0800 Merge branch 'pd-store' of github.com:apache/incubator-hugegraph into pd-store-jacky .editorconfig | 3 + .github/configs/settings.xml | 17 - .github/workflows/licence-checker.yml | 2 +- .licenserc.yaml | 39 +- hugegraph-pd/.gitignore | 2 - hugegraph-pd/build-pre.sh | 54 --- hugegraph-pd/build.sh | 39 -- hugegraph-pd/ci.yml | 43 -- hugegraph-pd/deploy-release.sh | 25 -- hugegraph-pd/deploy-snapshot.sh | 25 -- hugegraph-pd/hg-pd-client/pom.xml | 18 +- .../apache/hugegraph/pd/client/AbstractClient.java | 18 +- .../pd/client/AbstractClientStubProxy.java | 18 +- .../org/apache/hugegraph/pd/client/Channels.java | 18 +- .../apache/hugegraph/pd/client/ClientCache.java | 18 +- .../apache/hugegraph/pd/client/Discoverable.java | 18 +- .../hugegraph/pd/client/DiscoveryClient.java | 18 +- .../hugegraph/pd/client/DiscoveryClientImpl.java | 18 +- .../org/apache/hugegraph/pd/client/KvClient.java | 18 +- .../apache/hugegraph/pd/client/LicenseClient.java | 18 +- .../org/apache/hugegraph/pd/client/PDClient.java | 18 +- .../org/apache/hugegraph/pd/client/PDConfig.java | 18 +- .../org/apache/hugegraph/pd/client/PDPulse.java | 18 +- .../apache/hugegraph/pd/client/PDPulseImpl.java | 18 +- .../org/apache/hugegraph/pd/client/PDWatch.java | 18 +- .../apache/hugegraph/pd/client/PDWatchImpl.java | 18 +- .../apache/hugegraph/pd/pulse/PartitionNotice.java | 18 +- .../hugegraph/pd/pulse/PulseServerNotice.java | 18 +- .../org/apache/hugegraph/pd/watch/NodeEvent.java | 18 +- .../org/apache/hugegraph/pd/watch/PDWatcher.java | 18 +- .../apache/hugegraph/pd/watch/PartitionEvent.java | 18 +- .../org/apache/hugegraph/pd/watch/WatchType.java | 18 +- hugegraph-pd/hg-pd-clitools/pom.xml | 18 +- .../org/apache/hugegraph/pd/clitools/Main.java | 18 +- hugegraph-pd/hg-pd-common/pom.xml | 18 +- .../org/apache/hugegraph/pd/common/GraphCache.java | 18 +- .../org/apache/hugegraph/pd/common/HgAssert.java | 20 +- .../org/apache/hugegraph/pd/common/KVPair.java | 20 +- .../apache/hugegraph/pd/common/PDException.java | 18 +- .../hugegraph/pd/common/PDRuntimeException.java | 18 +- .../apache/hugegraph/pd/common/PartitionCache.java | 18 +- .../apache/hugegraph/pd/common/PartitionUtils.java | 18 +- hugegraph-pd/hg-pd-core/pom.xml | 18 +- .../org/apache/hugegraph/pd/ConfigService.java | 18 +- .../java/org/apache/hugegraph/pd/IdService.java | 18 +- .../java/org/apache/hugegraph/pd/KvService.java | 18 +- .../java/org/apache/hugegraph/pd/LogService.java | 18 +- .../hugegraph/pd/PartitionInstructionListener.java | 18 +- .../org/apache/hugegraph/pd/PartitionService.java | 18 +- .../hugegraph/pd/PartitionStatusListener.java | 18 +- .../org/apache/hugegraph/pd/RegistryService.java | 18 +- .../hugegraph/pd/ShardGroupStatusListener.java | 18 +- .../hugegraph/pd/StoreMonitorDataService.java | 18 +- .../org/apache/hugegraph/pd/StoreNodeService.java | 18 +- .../apache/hugegraph/pd/StoreStatusListener.java | 18 +- .../apache/hugegraph/pd/TaskScheduleService.java | 18 +- .../org/apache/hugegraph/pd/config/PDConfig.java | 18 +- .../apache/hugegraph/pd/meta/ConfigMetaStore.java | 18 +- .../hugegraph/pd/meta/DiscoveryMetaStore.java | 18 +- .../org/apache/hugegraph/pd/meta/IdMetaStore.java | 18 +- .../java/org/apache/hugegraph/pd/meta/LogMeta.java | 18 +- .../apache/hugegraph/pd/meta/MetadataFactory.java | 18 +- .../hugegraph/pd/meta/MetadataKeyHelper.java | 18 +- .../hugegraph/pd/meta/MetadataRocksDBStore.java | 18 +- .../hugegraph/pd/meta/MetadataStoreBase.java | 18 +- .../apache/hugegraph/pd/meta/PartitionMeta.java | 18 +- .../org/apache/hugegraph/pd/meta/QueueStore.java | 18 +- .../apache/hugegraph/pd/meta/StoreInfoMeta.java | 18 +- .../org/apache/hugegraph/pd/meta/TaskInfoMeta.java | 18 +- .../hugegraph/pd/raft/FutureClosureAdapter.java | 20 +- .../org/apache/hugegraph/pd/raft/KVOperation.java | 18 +- .../apache/hugegraph/pd/raft/KVStoreClosure.java | 20 +- .../org/apache/hugegraph/pd/raft/RaftEngine.java | 18 +- .../apache/hugegraph/pd/raft/RaftRpcClient.java | 18 +- .../apache/hugegraph/pd/raft/RaftRpcProcessor.java | 18 +- .../hugegraph/pd/raft/RaftStateListener.java | 18 +- .../apache/hugegraph/pd/raft/RaftStateMachine.java | 18 +- .../apache/hugegraph/pd/raft/RaftTaskHandler.java | 18 +- .../org/apache/hugegraph/pd/raft/ZipUtils.java | 18 +- .../hugegraph/pd/store/BaseKVStoreClosure.java | 18 +- .../org/apache/hugegraph/pd/store/HgKVStore.java | 18 +- .../apache/hugegraph/pd/store/HgKVStoreImpl.java | 18 +- .../java/org/apache/hugegraph/pd/store/KV.java | 18 +- .../org/apache/hugegraph/pd/store/RaftKVStore.java | 18 +- hugegraph-pd/hg-pd-dist/pom.xml | 18 +- .../src/assembly/descriptor/server-assembly.xml | 20 +- .../src/assembly/static/bin/start-hugegraph-pd.sh | 18 +- .../src/assembly/static/bin/stop-hugegraph-pd.sh | 18 +- .../hg-pd-dist/src/assembly/static/bin/util.sh | 18 +- .../hg-pd-dist/src/assembly/static/conf/log4j2.xml | 23 +- hugegraph-pd/hg-pd-grpc/pom.xml | 18 +- .../hg-pd-grpc/src/main/proto/discovery.proto | 19 +- hugegraph-pd/hg-pd-grpc/src/main/proto/kv.proto | 19 +- .../hg-pd-grpc/src/main/proto/metaTask.proto | 18 +- .../hg-pd-grpc/src/main/proto/metapb.proto | 19 +- .../hg-pd-grpc/src/main/proto/pd_common.proto | 19 +- .../hg-pd-grpc/src/main/proto/pd_pulse.proto | 19 +- .../hg-pd-grpc/src/main/proto/pd_watch.proto | 19 +- hugegraph-pd/hg-pd-grpc/src/main/proto/pdpb.proto | 19 +- hugegraph-pd/hg-pd-service/pom.xml | 18 +- .../org/apache/hugegraph/pd/boot/HugePDServer.java | 18 +- .../apache/hugegraph/pd/metrics/MetricsConfig.java | 18 +- .../org/apache/hugegraph/pd/metrics/PDMetrics.java | 18 +- .../org/apache/hugegraph/pd/model/DemoModel.java | 18 +- .../hugegraph/pd/model/GraphRestRequest.java | 18 +- .../hugegraph/pd/model/GraphSpaceRestRequest.java | 18 +- .../apache/hugegraph/pd/model/PeerRestRequest.java | 18 +- .../hugegraph/pd/model/PromTargetsModel.java | 18 +- .../pd/model/RegistryQueryRestRequest.java | 18 +- .../hugegraph/pd/model/RegistryRestRequest.java | 18 +- .../hugegraph/pd/model/RegistryRestResponse.java | 18 +- .../apache/hugegraph/pd/model/RestApiResponse.java | 18 +- .../hugegraph/pd/model/StoreRestRequest.java | 18 +- .../hugegraph/pd/model/TimeRangeRequest.java | 18 +- .../hugegraph/pd/notice/NoticeBroadcaster.java | 18 +- .../pd/pulse/AbstractObserverSubject.java | 18 +- .../apache/hugegraph/pd/pulse/PDPulseSubject.java | 18 +- .../pd/pulse/PartitionHeartbeatSubject.java | 18 +- .../hugegraph/pd/pulse/PdInstructionSubject.java | 18 +- .../apache/hugegraph/pd/pulse/PulseListener.java | 20 +- .../java/org/apache/hugegraph/pd/rest/API.java | 18 +- .../org/apache/hugegraph/pd/rest/GraphAPI.java | 20 +- .../apache/hugegraph/pd/rest/GraphSpaceAPI.java | 18 +- .../org/apache/hugegraph/pd/rest/IndexAPI.java | 18 +- .../org/apache/hugegraph/pd/rest/MemberAPI.java | 18 +- .../org/apache/hugegraph/pd/rest/PartitionAPI.java | 18 +- .../apache/hugegraph/pd/rest/PromTargetsAPI.java | 18 +- .../org/apache/hugegraph/pd/rest/RegistryAPI.java | 18 +- .../org/apache/hugegraph/pd/rest/ShardAPI.java | 18 +- .../org/apache/hugegraph/pd/rest/StoreAPI.java | 18 +- .../java/org/apache/hugegraph/pd/rest/TaskAPI.java | 18 +- .../java/org/apache/hugegraph/pd/rest/TestAPI.java | 18 +- .../hugegraph/pd/service/DiscoveryService.java | 18 +- .../hugegraph/pd/service/KvServiceGrpcImpl.java | 18 +- .../hugegraph/pd/service/PDPulseService.java | 18 +- .../apache/hugegraph/pd/service/PDRestService.java | 18 +- .../org/apache/hugegraph/pd/service/PDService.java | 18 +- .../hugegraph/pd/service/PDWatchService.java | 18 +- .../hugegraph/pd/service/PromTargetsService.java | 18 +- .../apache/hugegraph/pd/service/ServiceGrpc.java | 18 +- .../hugegraph/pd/service/UpgradeService.java | 18 +- .../hugegraph/pd/upgrade/VersionScriptFactory.java | 18 +- .../hugegraph/pd/upgrade/VersionUpgradeScript.java | 18 +- .../pd/upgrade/scripts/PartitionMetaUpgrade.java | 18 +- .../pd/upgrade/scripts/TaskCleanUpgrade.java | 18 +- .../org/apache/hugegraph/pd/util/DateUtil.java | 18 +- .../apache/hugegraph/pd/util/HgExecutorUtil.java | 18 +- .../org/apache/hugegraph/pd/util/HgMapCache.java | 18 +- .../java/org/apache/hugegraph/pd/util/IdUtil.java | 18 +- .../hugegraph/pd/util/grpc/GRpcServerConfig.java | 18 +- .../hugegraph/pd/util/grpc/StreamObserverUtil.java | 18 +- .../hugegraph/pd/watch/AbstractWatchSubject.java | 18 +- .../apache/hugegraph/pd/watch/KvWatchSubject.java | 18 +- .../hugegraph/pd/watch/NodeChangeSubject.java | 18 +- .../apache/hugegraph/pd/watch/PDWatchSubject.java | 18 +- .../hugegraph/pd/watch/PartitionChangeSubject.java | 18 +- .../pd/watch/ShardGroupChangeSubject.java | 18 +- .../hg-pd-service/src/main/resources/log4j2.xml | 18 +- .../org/apache/hugegraph/pd/live/PDServer0.java | 18 +- .../org/apache/hugegraph/pd/live/PDServer1.java | 18 +- .../org/apache/hugegraph/pd/live/PDServer2.java | 18 +- .../org/apache/hugegraph/pd/live/PDServer3.java | 18 +- .../hg-pd-service/src/test/resources/log4j2.xml | 18 +- hugegraph-pd/hg-pd-test/pom.xml | 18 +- .../apache/hugegraph/pd/MonitorServiceTest.java | 18 +- .../apache/hugegraph/pd/PartitionCacheTest.java | 18 +- .../apache/hugegraph/pd/PartitionServiceTest.java | 18 +- .../apache/hugegraph/pd/StoreNodeServiceTest.java | 18 +- .../org/apache/hugegraph/pd/StoreRegisterTest.java | 18 +- .../java/org/apache/hugegraph/pd/UnitTestBase.java | 18 +- .../apache/hugegraph/pd/client/BaseClientTest.java | 20 +- .../pd/client/DiscoveryClientImplTest.java | 20 +- .../hugegraph/pd/client/DiscoveryClientTest.java | 18 +- .../apache/hugegraph/pd/client/KvClientTest.java | 18 +- .../hugegraph/pd/client/LicenseClientImplTest.java | 18 +- .../hugegraph/pd/client/PDClientSuiteTest.java | 18 +- .../apache/hugegraph/pd/client/PDClientTest.java | 18 +- .../apache/hugegraph/pd/client/PDPulseTest.java | 23 +- .../apache/hugegraph/pd/client/PDWatchTest.java | 20 +- .../hugegraph/pd/client/test/HgPDTestUtil.java | 18 +- .../hugegraph/pd/clitools/BaseCliToolsTest.java | 20 +- .../hugegraph/pd/clitools/CliToolsSuiteTest.java | 20 +- .../org/apache/hugegraph/pd/clitools/MainTest.java | 20 +- .../apache/hugegraph/pd/common/BaseCommonTest.java | 20 +- .../hugegraph/pd/common/CommonSuiteTest.java | 20 +- .../apache/hugegraph/pd/common/HgAssertTest.java | 18 +- .../org/apache/hugegraph/pd/common/KVPairTest.java | 18 +- .../hugegraph/pd/common/MetadataKeyHelperTest.java | 18 +- .../hugegraph/pd/common/PartitionCacheTest.java | 18 +- .../hugegraph/pd/common/PartitionUtilsTest.java | 18 +- .../org/apache/hugegraph/pd/core/BaseCoreTest.java | 20 +- .../apache/hugegraph/pd/core/PDCoreSuiteTest.java | 20 +- .../hugegraph/pd/core/StoreNodeServiceTest.java | 20 +- .../pd/core/meta/MetadataKeyHelperTest.java | 18 +- .../org/apache/hugegraph/pd/grpc/BaseGrpcTest.java | 20 +- .../apache/hugegraph/pd/grpc/GrpcSuiteTest.java | 18 +- .../hugegraph/pd/service/BaseServerTest.java | 20 +- .../hugegraph/pd/service/ConfigServiceTest.java | 18 +- .../apache/hugegraph/pd/service/IdServiceTest.java | 18 +- .../apache/hugegraph/pd/service/KvServiceTest.java | 18 +- .../hugegraph/pd/service/LogServiceTest.java | 18 +- .../hugegraph/pd/service/PartitionServiceTest.java | 18 +- .../apache/hugegraph/pd/service/PdTestBase.java | 18 +- .../apache/hugegraph/pd/service/RestApiTest.java | 18 +- .../hugegraph/pd/service/ServerSuiteTest.java | 18 +- .../pd/service/StoreMonitorDataServiceTest.java | 18 +- .../pd/service/StoreNodeServiceNewTest.java | 18 +- .../hugegraph/pd/service/StoreServiceTest.java | 18 +- .../pd/service/TaskScheduleServiceTest.java | 18 +- .../hugegraph/pd/store/HgKVStoreImplTest.java | 18 +- .../hg-pd-test/src/main/resources/log4j2.xml | 18 +- hugegraph-pd/local-release.sh | 25 -- hugegraph-pd/pom.xml | 20 +- hugegraph-pd/settings.xml | 133 ------ hugegraph-server/hugegraph-api/pom.xml | 18 +- .../main/java/org/apache/hugegraph/api/API.java | 33 +- .../org/apache/hugegraph/api/arthas/ArthasAPI.java | 22 +- .../org/apache/hugegraph/api/auth/AccessAPI.java | 54 +-- .../org/apache/hugegraph/api/auth/BelongAPI.java | 52 +-- .../org/apache/hugegraph/api/auth/GroupAPI.java | 52 +-- .../org/apache/hugegraph/api/auth/LoginAPI.java | 18 +- .../org/apache/hugegraph/api/auth/ProjectAPI.java | 54 +-- .../org/apache/hugegraph/api/auth/TargetAPI.java | 50 +-- .../org/apache/hugegraph/api/auth/UserAPI.java | 54 +-- .../org/apache/hugegraph/api/cypher/CypherAPI.java | 19 +- .../apache/hugegraph/api/cypher/CypherClient.java | 44 +- .../apache/hugegraph/api/cypher/CypherManager.java | 18 +- .../apache/hugegraph/api/cypher/CypherModel.java | 20 +- .../hugegraph/api/filter/AccessLogFilter.java | 18 +- .../hugegraph/api/filter/AuthenticationFilter.java | 28 +- .../hugegraph/api/filter/CompressInterceptor.java | 37 +- .../api/filter/DecompressInterceptor.java | 22 +- .../hugegraph/api/filter/ExceptionFilter.java | 70 ++-- .../hugegraph/api/filter/LoadDetectFilter.java | 55 +-- .../hugegraph/api/filter/LoadReleaseFilter.java | 22 +- .../apache/hugegraph/api/filter/PathFilter.java | 18 +- .../hugegraph/api/filter/RedirectFilter.java | 19 +- .../api/filter/RedirectFilterDynamicFeature.java | 18 +- .../apache/hugegraph/api/filter/StatusFilter.java | 21 +- .../org/apache/hugegraph/api/graph/BatchAPI.java | 55 ++- .../org/apache/hugegraph/api/graph/EdgeAPI.java | 184 ++++----- .../org/apache/hugegraph/api/graph/VertexAPI.java | 116 +++--- .../api/gremlin/AbstractJerseyRestClient.java | 20 +- .../apache/hugegraph/api/gremlin/GremlinAPI.java | 34 +- .../hugegraph/api/gremlin/GremlinClient.java | 18 +- .../hugegraph/api/gremlin/GremlinQueryAPI.java | 19 +- .../org/apache/hugegraph/api/job/AlgorithmAPI.java | 19 +- .../org/apache/hugegraph/api/job/ComputerAPI.java | 18 +- .../org/apache/hugegraph/api/job/GremlinAPI.java | 22 +- .../org/apache/hugegraph/api/job/RebuildAPI.java | 18 +- .../java/org/apache/hugegraph/api/job/TaskAPI.java | 30 +- .../apache/hugegraph/api/metrics/MetricsAPI.java | 20 +- .../apache/hugegraph/api/profile/GraphsAPI.java | 66 +-- .../apache/hugegraph/api/profile/ProfileAPI.java | 49 ++- .../apache/hugegraph/api/profile/VersionAPI.java | 37 +- .../hugegraph/api/profile/WhiteIpListAPI.java | 24 +- .../org/apache/hugegraph/api/raft/RaftAPI.java | 52 +-- .../apache/hugegraph/api/schema/EdgeLabelAPI.java | 18 +- .../apache/hugegraph/api/schema/IndexLabelAPI.java | 18 +- .../hugegraph/api/schema/PropertyKeyAPI.java | 18 +- .../org/apache/hugegraph/api/schema/SchemaAPI.java | 18 +- .../hugegraph/api/schema/VertexLabelAPI.java | 18 +- .../hugegraph/api/traversers/AdamicAdarAPI.java | 39 +- .../api/traversers/AllShortestPathsAPI.java | 18 +- .../apache/hugegraph/api/traversers/CountAPI.java | 40 +- .../hugegraph/api/traversers/CrosspointsAPI.java | 18 +- .../api/traversers/CustomizedCrosspointsAPI.java | 19 +- .../api/traversers/CustomizedPathsAPI.java | 18 +- .../hugegraph/api/traversers/EdgeExistenceAPI.java | 19 +- .../apache/hugegraph/api/traversers/EdgesAPI.java | 18 +- .../api/traversers/FusiformSimilarityAPI.java | 18 +- .../api/traversers/JaccardSimilarityAPI.java | 18 +- .../hugegraph/api/traversers/KneighborAPI.java | 18 +- .../apache/hugegraph/api/traversers/KoutAPI.java | 18 +- .../api/traversers/MultiNodeShortestPathAPI.java | 18 +- .../hugegraph/api/traversers/NeighborRankAPI.java | 40 +- .../apache/hugegraph/api/traversers/PathsAPI.java | 18 +- .../hugegraph/api/traversers/PersonalRankAPI.java | 38 +- .../apache/hugegraph/api/traversers/RaysAPI.java | 18 +- .../api/traversers/ResourceAllocationAPI.java | 39 +- .../apache/hugegraph/api/traversers/RingsAPI.java | 18 +- .../hugegraph/api/traversers/SameNeighborsAPI.java | 18 +- .../hugegraph/api/traversers/ShortestPathAPI.java | 18 +- .../traversers/SingleSourceShortestPathAPI.java | 18 +- .../hugegraph/api/traversers/TemplatePathsAPI.java | 18 +- .../hugegraph/api/traversers/TraverserAPI.java | 18 +- .../apache/hugegraph/api/traversers/Vertices.java | 35 +- .../hugegraph/api/traversers/VerticesAPI.java | 18 +- .../api/traversers/WeightedShortestPathAPI.java | 18 +- .../hugegraph/api/variables/VariablesAPI.java | 40 +- .../apache/hugegraph/auth/ConfigAuthenticator.java | 23 +- .../hugegraph/auth/ContextGremlinServer.java | 26 +- .../apache/hugegraph/auth/HugeAuthenticator.java | 28 +- .../hugegraph/auth/HugeFactoryAuthProxy.java | 459 +++++++++++++++++---- .../apache/hugegraph/auth/HugeGraphAuthProxy.java | 80 ++-- .../hugegraph/auth/StandardAuthenticator.java | 25 +- .../hugegraph/auth/WsAndHttpBasicAuthHandler.java | 28 +- .../org/apache/hugegraph/config/ServerOptions.java | 66 +-- .../org/apache/hugegraph/core/GraphManager.java | 35 +- .../org/apache/hugegraph/define/Checkable.java | 18 +- .../apache/hugegraph/define/UpdateStrategy.java | 27 +- .../java/org/apache/hugegraph/define/WorkLoad.java | 18 +- .../org/apache/hugegraph/metrics/MetricsKeys.java | 18 +- .../apache/hugegraph/metrics/MetricsModule.java | 20 +- .../org/apache/hugegraph/metrics/MetricsUtil.java | 19 +- .../apache/hugegraph/metrics/ServerReporter.java | 23 +- .../org/apache/hugegraph/metrics/SlowQueryLog.java | 18 +- .../apache/hugegraph/metrics/SystemMetrics.java | 23 +- .../hugegraph/opencypher/CypherOpProcessor.java | 38 +- .../apache/hugegraph/opencypher/CypherPlugin.java | 28 +- .../hugegraph/rpc/RpcClientProviderWithAuth.java | 21 +- .../hugegraph/serializer/JsonSerializer.java | 18 +- .../apache/hugegraph/serializer/Serializer.java | 18 +- .../apache/hugegraph/server/ApplicationConfig.java | 50 +-- .../org/apache/hugegraph/server/RestServer.java | 41 +- .../org/apache/hugegraph/version/ApiVersion.java | 18 +- hugegraph-server/hugegraph-cassandra/pom.xml | 18 +- .../datastax/driver/core/querybuilder/Clauses.java | 18 +- .../store/cassandra/CassandraBackendEntry.java | 18 +- .../store/cassandra/CassandraEntryIterator.java | 20 +- .../backend/store/cassandra/CassandraFeatures.java | 18 +- .../backend/store/cassandra/CassandraMetrics.java | 24 +- .../backend/store/cassandra/CassandraOptions.java | 18 +- .../store/cassandra/CassandraSerializer.java | 19 +- .../store/cassandra/CassandraSessionPool.java | 19 +- .../backend/store/cassandra/CassandraShard.java | 60 +-- .../backend/store/cassandra/CassandraStore.java | 68 ++- .../store/cassandra/CassandraStoreProvider.java | 18 +- .../backend/store/cassandra/CassandraTable.java | 53 ++- .../backend/store/cassandra/CassandraTables.java | 28 +- hugegraph-server/hugegraph-core/pom.xml | 18 +- .../java/org/apache/hugegraph/HugeException.java | 18 +- .../java/org/apache/hugegraph/HugeFactory.java | 21 +- .../main/java/org/apache/hugegraph/HugeGraph.java | 24 +- .../java/org/apache/hugegraph/HugeGraphParams.java | 27 +- .../org/apache/hugegraph/StandardHugeGraph.java | 104 +++-- .../org/apache/hugegraph/analyzer/Analyzer.java | 18 +- .../apache/hugegraph/analyzer/AnalyzerFactory.java | 24 +- .../apache/hugegraph/analyzer/AnsjAnalyzer.java | 26 +- .../apache/hugegraph/analyzer/HanLPAnalyzer.java | 41 +- .../org/apache/hugegraph/analyzer/IKAnalyzer.java | 26 +- .../apache/hugegraph/analyzer/JcsegAnalyzer.java | 26 +- .../apache/hugegraph/analyzer/JiebaAnalyzer.java | 23 +- .../apache/hugegraph/analyzer/MMSeg4JAnalyzer.java | 25 +- .../apache/hugegraph/analyzer/SmartCNAnalyzer.java | 23 +- .../org/apache/hugegraph/auth/AuthConstant.java | 18 +- .../org/apache/hugegraph/auth/AuthManager.java | 20 +- .../org/apache/hugegraph/auth/EntityManager.java | 34 +- .../java/org/apache/hugegraph/auth/HugeAccess.java | 25 +- .../java/org/apache/hugegraph/auth/HugeBelong.java | 33 +- .../java/org/apache/hugegraph/auth/HugeGroup.java | 27 +- .../org/apache/hugegraph/auth/HugePermission.java | 18 +- .../org/apache/hugegraph/auth/HugeProject.java | 25 +- .../org/apache/hugegraph/auth/HugeResource.java | 37 +- .../java/org/apache/hugegraph/auth/HugeTarget.java | 27 +- .../java/org/apache/hugegraph/auth/HugeUser.java | 25 +- .../apache/hugegraph/auth/RelationshipManager.java | 36 +- .../org/apache/hugegraph/auth/ResourceObject.java | 20 +- .../org/apache/hugegraph/auth/ResourceType.java | 27 +- .../org/apache/hugegraph/auth/RolePermission.java | 44 +- .../org/apache/hugegraph/auth/SchemaDefine.java | 30 +- .../apache/hugegraph/auth/StandardAuthManager.java | 36 +- .../org/apache/hugegraph/auth/TokenGenerator.java | 20 +- .../org/apache/hugegraph/auth/UserWithRole.java | 18 +- .../apache/hugegraph/backend/BackendException.java | 20 +- .../org/apache/hugegraph/backend/LocalCounter.java | 18 +- .../org/apache/hugegraph/backend/Transaction.java | 18 +- .../hugegraph/backend/cache/AbstractCache.java | 23 +- .../org/apache/hugegraph/backend/cache/Cache.java | 18 +- .../hugegraph/backend/cache/CacheManager.java | 25 +- .../hugegraph/backend/cache/CacheNotifier.java | 26 +- .../backend/cache/CachedBackendStore.java | 20 +- .../backend/cache/CachedGraphTransaction.java | 29 +- .../backend/cache/CachedSchemaTransaction.java | 27 +- .../apache/hugegraph/backend/cache/LevelCache.java | 18 +- .../hugegraph/backend/cache/OffheapCache.java | 41 +- .../apache/hugegraph/backend/cache/RamCache.java | 30 +- .../org/apache/hugegraph/backend/id/EdgeId.java | 58 +-- .../java/org/apache/hugegraph/backend/id/Id.java | 20 +- .../apache/hugegraph/backend/id/IdGenerator.java | 18 +- .../org/apache/hugegraph/backend/id/IdUtil.java | 19 +- .../hugegraph/backend/id/SnowflakeIdGenerator.java | 13 +- .../hugegraph/backend/id/SplicingIdGenerator.java | 36 +- .../apache/hugegraph/backend/page/IdHolder.java | 25 +- .../hugegraph/backend/page/IdHolderList.java | 18 +- .../hugegraph/backend/page/PageEntryIterator.java | 21 +- .../org/apache/hugegraph/backend/page/PageIds.java | 19 +- .../apache/hugegraph/backend/page/PageInfo.java | 18 +- .../apache/hugegraph/backend/page/PageState.java | 18 +- .../apache/hugegraph/backend/page/QueryList.java | 44 +- .../backend/page/SortByCountIdHolderList.java | 21 +- .../apache/hugegraph/backend/query/Aggregate.java | 18 +- .../backend/query/BatchConditionQuery.java | 20 +- .../apache/hugegraph/backend/query/Condition.java | 66 +-- .../hugegraph/backend/query/ConditionQuery.java | 64 ++- .../backend/query/ConditionQueryFlatten.java | 20 +- .../backend/query/EdgesQueryIterator.java | 18 +- .../hugegraph/backend/query/IdPrefixQuery.java | 18 +- .../apache/hugegraph/backend/query/IdQuery.java | 21 +- .../hugegraph/backend/query/IdRangeQuery.java | 18 +- .../org/apache/hugegraph/backend/query/Query.java | 26 +- .../hugegraph/backend/query/QueryResults.java | 33 +- .../backend/serializer/AbstractSerializer.java | 26 +- .../backend/serializer/BinaryBackendEntry.java | 18 +- .../backend/serializer/BinaryEntryIterator.java | 18 +- .../serializer/BinaryScatterSerializer.java | 20 +- .../backend/serializer/BinarySerializer.java | 49 ++- .../hugegraph/backend/serializer/BytesBuffer.java | 34 +- .../backend/serializer/GraphSerializer.java | 21 +- .../backend/serializer/MergeIterator.java | 22 +- .../backend/serializer/SchemaSerializer.java | 18 +- .../backend/serializer/SerializerFactory.java | 20 +- .../backend/serializer/TableBackendEntry.java | 19 +- .../backend/serializer/TableSerializer.java | 41 +- .../backend/serializer/TextBackendEntry.java | 21 +- .../backend/serializer/TextSerializer.java | 49 ++- .../backend/store/AbstractBackendStore.java | 26 +- .../store/AbstractBackendStoreProvider.java | 28 +- .../hugegraph/backend/store/BackendAction.java | 18 +- .../hugegraph/backend/store/BackendEntry.java | 18 +- .../backend/store/BackendEntryIterator.java | 19 +- .../hugegraph/backend/store/BackendFeatures.java | 18 +- .../hugegraph/backend/store/BackendMetrics.java | 18 +- .../hugegraph/backend/store/BackendMutation.java | 59 +-- .../backend/store/BackendProviderFactory.java | 25 +- .../hugegraph/backend/store/BackendSession.java | 18 +- .../backend/store/BackendSessionPool.java | 23 +- .../hugegraph/backend/store/BackendStore.java | 27 +- .../hugegraph/backend/store/BackendStoreInfo.java | 21 +- .../backend/store/BackendStoreProvider.java | 21 +- .../hugegraph/backend/store/BackendTable.java | 22 +- .../hugegraph/backend/store/MetaDispatcher.java | 18 +- .../hugegraph/backend/store/MetaHandler.java | 18 +- .../org/apache/hugegraph/backend/store/Shard.java | 18 +- .../hugegraph/backend/store/SystemSchemaStore.java | 18 +- .../hugegraph/backend/store/TableDefine.java | 19 +- .../backend/store/memory/InMemoryDBStore.java | 30 +- .../store/memory/InMemoryDBStoreProvider.java | 20 +- .../backend/store/memory/InMemoryDBTable.java | 46 +-- .../backend/store/memory/InMemoryDBTables.java | 71 ++-- .../backend/store/memory/InMemoryMetrics.java | 19 +- .../backend/store/raft/RaftAddPeerJob.java | 18 +- .../backend/store/raft/RaftBackendStore.java | 36 +- .../store/raft/RaftBackendStoreProvider.java | 25 +- .../hugegraph/backend/store/raft/RaftClosure.java | 22 +- .../hugegraph/backend/store/raft/RaftContext.java | 62 +-- .../backend/store/raft/RaftException.java | 20 +- .../backend/store/raft/RaftGroupManager.java | 18 +- .../backend/store/raft/RaftGroupManagerImpl.java | 38 +- .../hugegraph/backend/store/raft/RaftNode.java | 44 +- .../backend/store/raft/RaftRemovePeerJob.java | 18 +- .../hugegraph/backend/store/raft/RaftResult.java | 21 +- .../backend/store/raft/RaftStoreClosure.java | 18 +- .../hugegraph/backend/store/raft/StoreCommand.java | 18 +- .../backend/store/raft/StoreSerializer.java | 20 +- .../backend/store/raft/StoreSnapshotFile.java | 20 +- .../backend/store/raft/StoreStateMachine.java | 40 +- .../store/raft/compress/CompressStrategy.java | 18 +- .../raft/compress/CompressStrategyManager.java | 24 +- .../raft/compress/ParallelCompressStrategy.java | 34 +- .../raft/compress/SerialCompressStrategy.java | 18 +- .../backend/store/raft/rpc/AddPeerProcessor.java | 29 +- .../backend/store/raft/rpc/ListPeersProcessor.java | 30 +- .../store/raft/rpc/RemovePeerProcessor.java | 29 +- .../backend/store/raft/rpc/RpcForwarder.java | 59 +-- .../backend/store/raft/rpc/SetLeaderProcessor.java | 22 +- .../store/raft/rpc/StoreCommandProcessor.java | 28 +- .../hugegraph/backend/store/ram/IntIntMap.java | 18 +- .../hugegraph/backend/store/ram/IntLongMap.java | 18 +- .../hugegraph/backend/store/ram/IntObjectMap.java | 18 +- .../apache/hugegraph/backend/store/ram/RamMap.java | 18 +- .../hugegraph/backend/store/ram/RamTable.java | 32 +- .../hugegraph/backend/tx/AbstractTransaction.java | 34 +- .../backend/tx/GraphIndexTransaction.java | 165 ++++---- .../hugegraph/backend/tx/GraphTransaction.java | 211 ++++++---- .../hugegraph/backend/tx/IndexableTransaction.java | 22 +- .../backend/tx/SchemaIndexTransaction.java | 25 +- .../hugegraph/backend/tx/SchemaTransaction.java | 57 +-- .../org/apache/hugegraph/config/AuthOptions.java | 18 +- .../org/apache/hugegraph/config/CoreOptions.java | 65 +-- .../hugegraph/exception/ConnectionException.java | 18 +- .../hugegraph/exception/ExistedException.java | 18 +- .../hugegraph/exception/HugeGremlinException.java | 18 +- .../hugegraph/exception/LimitExceedException.java | 18 +- .../hugegraph/exception/NoIndexException.java | 18 +- .../hugegraph/exception/NotAllowException.java | 18 +- .../hugegraph/exception/NotFoundException.java | 18 +- .../hugegraph/exception/NotSupportException.java | 18 +- .../hugegraph/io/GraphSONSchemaSerializer.java | 18 +- .../apache/hugegraph/io/HugeGraphIoRegistry.java | 20 +- .../apache/hugegraph/io/HugeGraphSONModule.java | 83 ++-- .../org/apache/hugegraph/io/HugeGryoModule.java | 20 +- .../org/apache/hugegraph/job/AlgorithmJob.java | 18 +- .../java/org/apache/hugegraph/job/ComputerJob.java | 20 +- .../org/apache/hugegraph/job/EphemeralJob.java | 18 +- .../apache/hugegraph/job/EphemeralJobBuilder.java | 20 +- .../java/org/apache/hugegraph/job/GremlinJob.java | 30 +- .../main/java/org/apache/hugegraph/job/Job.java | 18 +- .../java/org/apache/hugegraph/job/JobBuilder.java | 20 +- .../main/java/org/apache/hugegraph/job/SysJob.java | 18 +- .../java/org/apache/hugegraph/job/UserJob.java | 18 +- .../hugegraph/job/algorithm/AbstractAlgorithm.java | 50 +-- .../apache/hugegraph/job/algorithm/Algorithm.java | 18 +- .../hugegraph/job/algorithm/AlgorithmPool.java | 24 +- .../hugegraph/job/algorithm/BfsTraverser.java | 25 +- .../apache/hugegraph/job/algorithm/Consumers.java | 23 +- .../job/algorithm/CountEdgeAlgorithm.java | 21 +- .../job/algorithm/CountVertexAlgorithm.java | 21 +- .../job/algorithm/SubgraphStatAlgorithm.java | 32 +- .../job/algorithm/cent/AbstractCentAlgorithm.java | 71 ++-- .../cent/BetweennessCentralityAlgorithm.java | 31 +- .../cent/BetweennessCentralityAlgorithmV2.java | 29 +- .../cent/ClosenessCentralityAlgorithm.java | 27 +- .../cent/ClosenessCentralityAlgorithmV2.java | 31 +- .../algorithm/cent/DegreeCentralityAlgorithm.java | 25 +- .../cent/EigenvectorCentralityAlgorithm.java | 23 +- .../algorithm/cent/StressCentralityAlgorithm.java | 25 +- .../cent/StressCentralityAlgorithmV2.java | 28 +- .../job/algorithm/comm/AbstractCommAlgorithm.java | 18 +- .../comm/ClusterCoefficientAlgorithm.java | 20 +- .../job/algorithm/comm/KCoreAlgorithm.java | 34 +- .../job/algorithm/comm/LouvainAlgorithm.java | 22 +- .../job/algorithm/comm/LouvainTraverser.java | 64 +-- .../hugegraph/job/algorithm/comm/LpaAlgorithm.java | 28 +- .../job/algorithm/comm/TriangleCountAlgorithm.java | 18 +- .../job/algorithm/comm/WeakConnectedComponent.java | 39 +- .../job/algorithm/path/RingsDetectAlgorithm.java | 18 +- .../job/algorithm/rank/PageRankAlgorithm.java | 51 ++- .../similarity/FusiformSimilarityAlgorithm.java | 33 +- .../hugegraph/job/computer/AbstractComputer.java | 38 +- .../apache/hugegraph/job/computer/Computer.java | 18 +- .../hugegraph/job/computer/ComputerPool.java | 18 +- .../hugegraph/job/computer/LouvainComputer.java | 23 +- .../apache/hugegraph/job/computer/LpaComputer.java | 21 +- .../hugegraph/job/computer/PageRankComputer.java | 21 +- .../job/computer/TriangleCountComputer.java | 20 +- .../computer/WeakConnectedComponentComputer.java | 20 +- .../hugegraph/job/schema/EdgeLabelRemoveJob.java | 21 +- .../hugegraph/job/schema/IndexLabelRebuildJob.java | 34 +- .../hugegraph/job/schema/IndexLabelRemoveJob.java | 20 +- .../job/schema/OlapPropertyKeyClearJob.java | 20 +- .../job/schema/OlapPropertyKeyCreateJob.java | 18 +- .../job/schema/OlapPropertyKeyRemoveJob.java | 18 +- .../org/apache/hugegraph/job/schema/SchemaJob.java | 45 +- .../hugegraph/job/schema/VertexLabelRemoveJob.java | 29 +- .../job/system/DeleteExpiredElementJob.java | 20 +- .../job/system/DeleteExpiredIndexJob.java | 22 +- .../hugegraph/job/system/DeleteExpiredJob.java | 27 +- .../apache/hugegraph/job/system/JobCounters.java | 22 +- .../hugegraph/masterelection/ClusterRole.java | 26 +- .../hugegraph/masterelection/ClusterRoleStore.java | 18 +- .../apache/hugegraph/masterelection/Config.java | 18 +- .../hugegraph/masterelection/GlobalMasterInfo.java | 18 +- .../masterelection/RoleElectionConfig.java | 18 +- .../masterelection/RoleElectionOptions.java | 20 +- .../masterelection/RoleElectionStateMachine.java | 18 +- .../hugegraph/masterelection/RoleListener.java | 18 +- .../masterelection/StandardClusterRoleStore.java | 19 +- .../StandardRoleElectionStateMachine.java | 18 +- .../masterelection/StandardRoleListener.java | 20 +- .../masterelection/StateMachineContext.java | 18 +- .../org/apache/hugegraph/meta/MetaManager.java | 5 +- .../hugegraph/plugin/HugeGraphGremlinPlugin.java | 24 +- .../apache/hugegraph/plugin/HugeGraphPlugin.java | 20 +- .../hugegraph/rpc/RpcServiceConfig4Client.java | 18 +- .../hugegraph/rpc/RpcServiceConfig4Server.java | 18 +- .../org/apache/hugegraph/schema/EdgeLabel.java | 38 +- .../org/apache/hugegraph/schema/IndexLabel.java | 37 +- .../org/apache/hugegraph/schema/PropertyKey.java | 45 +- .../org/apache/hugegraph/schema/SchemaElement.java | 28 +- .../org/apache/hugegraph/schema/SchemaLabel.java | 41 +- .../org/apache/hugegraph/schema/SchemaManager.java | 40 +- .../java/org/apache/hugegraph/schema/Userdata.java | 24 +- .../org/apache/hugegraph/schema/VertexLabel.java | 20 +- .../hugegraph/schema/builder/AbstractBuilder.java | 24 +- .../hugegraph/schema/builder/EdgeLabelBuilder.java | 73 ++-- .../schema/builder/IndexLabelBuilder.java | 29 +- .../schema/builder/PropertyKeyBuilder.java | 66 ++- .../hugegraph/schema/builder/SchemaBuilder.java | 18 +- .../schema/builder/VertexLabelBuilder.java | 67 +-- .../hugegraph/security/HugeSecurityManager.java | 75 ++-- .../org/apache/hugegraph/structure/GraphType.java | 19 +- .../org/apache/hugegraph/structure/HugeEdge.java | 26 +- .../hugegraph/structure/HugeEdgeProperty.java | 21 +- .../apache/hugegraph/structure/HugeElement.java | 34 +- .../apache/hugegraph/structure/HugeFeatures.java | 36 +- .../org/apache/hugegraph/structure/HugeIndex.java | 20 +- .../apache/hugegraph/structure/HugeProperty.java | 21 +- .../org/apache/hugegraph/structure/HugeVertex.java | 33 +- .../hugegraph/structure/HugeVertexProperty.java | 27 +- .../apache/hugegraph/task/EphemeralJobQueue.java | 24 +- .../org/apache/hugegraph/task/HugeServerInfo.java | 40 +- .../java/org/apache/hugegraph/task/HugeTask.java | 69 ++-- .../apache/hugegraph/task/ServerInfoManager.java | 24 +- .../hugegraph/task/StandardTaskScheduler.java | 54 ++- .../org/apache/hugegraph/task/TaskCallable.java | 24 +- .../org/apache/hugegraph/task/TaskManager.java | 34 +- .../org/apache/hugegraph/task/TaskScheduler.java | 26 +- .../java/org/apache/hugegraph/task/TaskStatus.java | 23 +- .../algorithm/CollectionPathsTraverser.java | 18 +- .../traversal/algorithm/CountTraverser.java | 23 +- .../algorithm/CustomizePathsTraverser.java | 18 +- .../algorithm/CustomizedCrosspointsTraverser.java | 18 +- .../algorithm/EdgeExistenceTraverser.java | 18 +- .../algorithm/FusiformSimilarityTraverser.java | 20 +- .../traversal/algorithm/HugeTraverser.java | 27 +- .../algorithm/JaccardSimilarTraverser.java | 20 +- .../traversal/algorithm/KneighborTraverser.java | 20 +- .../traversal/algorithm/KoutTraverser.java | 20 +- .../algorithm/MultiNodeShortestPathTraverser.java | 18 +- .../traversal/algorithm/NeighborRankTraverser.java | 31 +- .../traversal/algorithm/OltpTraverser.java | 24 +- .../traversal/algorithm/PathTraverser.java | 18 +- .../traversal/algorithm/PathsTraverser.java | 20 +- .../traversal/algorithm/PersonalRankTraverser.java | 25 +- .../traversal/algorithm/PredictionTraverser.java | 19 +- .../traversal/algorithm/SameNeighborTraverser.java | 22 +- .../traversal/algorithm/ShortestPathTraverser.java | 31 +- .../SingleSourceShortestPathTraverser.java | 22 +- .../traversal/algorithm/SubGraphTraverser.java | 20 +- .../algorithm/TemplatePathsTraverser.java | 18 +- .../algorithm/iterator/NestedIterator.java | 18 +- .../algorithm/records/AbstractRecords.java | 22 +- .../records/DoubleWayMultiPathsRecords.java | 22 +- .../algorithm/records/KneighborRecords.java | 18 +- .../traversal/algorithm/records/KoutRecords.java | 20 +- .../traversal/algorithm/records/PathsRecords.java | 18 +- .../traversal/algorithm/records/Records.java | 18 +- .../algorithm/records/ShortestPathRecords.java | 18 +- .../records/SingleWayMultiPathsRecords.java | 18 +- .../algorithm/records/record/Int2ArrayRecord.java | 18 +- .../algorithm/records/record/Int2IntRecord.java | 18 +- .../algorithm/records/record/Int2SetRecord.java | 18 +- .../traversal/algorithm/records/record/Record.java | 18 +- .../algorithm/records/record/RecordFactory.java | 18 +- .../algorithm/records/record/RecordType.java | 18 +- .../algorithm/records/record/SyncRecord.java | 20 +- .../traversal/algorithm/steps/EdgeStep.java | 24 +- .../traversal/algorithm/steps/RepeatEdgeStep.java | 19 +- .../hugegraph/traversal/algorithm/steps/Steps.java | 18 +- .../algorithm/steps/WeightedEdgeStep.java | 19 +- .../strategy/ConcurrentTraverseStrategy.java | 20 +- .../algorithm/strategy/SingleTraverseStrategy.java | 28 +- .../algorithm/strategy/TraverseStrategy.java | 22 +- .../hugegraph/traversal/optimize/ConditionP.java | 18 +- .../traversal/optimize/HugeCountStep.java | 26 +- .../traversal/optimize/HugeCountStepStrategy.java | 38 +- .../traversal/optimize/HugeGraphStep.java | 23 +- .../traversal/optimize/HugeGraphStepStrategy.java | 26 +- .../traversal/optimize/HugePrimaryKeyStrategy.java | 22 +- .../traversal/optimize/HugeScriptTraversal.java | 4 +- .../traversal/optimize/HugeVertexStep.java | 44 +- .../traversal/optimize/HugeVertexStepByBatch.java | 35 +- .../traversal/optimize/HugeVertexStepStrategy.java | 36 +- .../hugegraph/traversal/optimize/QueryHolder.java | 21 +- .../apache/hugegraph/traversal/optimize/Text.java | 18 +- .../traversal/optimize/TraversalUtil.java | 48 +-- .../java/org/apache/hugegraph/type/HugeType.java | 18 +- .../java/org/apache/hugegraph/type/Idfiable.java | 18 +- .../java/org/apache/hugegraph/type/Indexable.java | 18 +- .../java/org/apache/hugegraph/type/Nameable.java | 1 + .../org/apache/hugegraph/type/Propertiable.java | 18 +- .../java/org/apache/hugegraph/type/Typeable.java | 18 +- .../org/apache/hugegraph/type/define/Action.java | 18 +- .../hugegraph/type/define/AggregateType.java | 18 +- .../hugegraph/type/define/CollectionType.java | 20 +- .../org/apache/hugegraph/type/define/DataType.java | 30 +- .../apache/hugegraph/type/define/Directions.java | 26 +- .../apache/hugegraph/type/define/Frequency.java | 18 +- .../apache/hugegraph/type/define/GraphMode.java | 18 +- .../hugegraph/type/define/GraphReadMode.java | 18 +- .../org/apache/hugegraph/type/define/HugeKeys.java | 18 +- .../apache/hugegraph/type/define/IdStrategy.java | 18 +- .../apache/hugegraph/type/define/IndexType.java | 20 +- .../org/apache/hugegraph/type/define/NodeRole.java | 18 +- .../apache/hugegraph/type/define/SchemaStatus.java | 18 +- .../apache/hugegraph/type/define/SerialEnum.java | 19 +- .../apache/hugegraph/type/define/WriteType.java | 18 +- .../main/java/org/apache/hugegraph/util/Blob.java | 18 +- .../org/apache/hugegraph/util/CompressUtil.java | 31 +- .../java/org/apache/hugegraph/util/ConfigUtil.java | 35 +- .../java/org/apache/hugegraph/util/Consumers.java | 20 +- .../java/org/apache/hugegraph/util/CopyUtil.java | 18 +- .../java/org/apache/hugegraph/util/Events.java | 18 +- .../util/FixedTimerWindowRateLimiter.java | 20 +- .../util/FixedWatchWindowRateLimiter.java | 22 +- .../java/org/apache/hugegraph/util/GZipUtil.java | 19 +- .../java/org/apache/hugegraph/util/JsonUtil.java | 29 +- .../java/org/apache/hugegraph/util/KryoUtil.java | 20 +- .../java/org/apache/hugegraph/util/LZ4Util.java | 18 +- .../java/org/apache/hugegraph/util/LockUtil.java | 38 +- .../org/apache/hugegraph/util/ParameterUtil.java | 20 +- .../org/apache/hugegraph/util/RateLimiter.java | 21 +- .../java/org/apache/hugegraph/util/Reflection.java | 44 +- .../org/apache/hugegraph/util/StringEncoding.java | 1 - .../util/collection/CollectionFactory.java | 47 ++- .../apache/hugegraph/util/collection/IdSet.java | 27 +- .../hugegraph/util/collection/Int2IntsMap.java | 20 +- .../hugegraph/util/collection/IntIterator.java | 22 +- .../apache/hugegraph/util/collection/IntMap.java | 41 +- .../util/collection/IntMapByDynamicHash.java | 54 +-- .../apache/hugegraph/util/collection/IntSet.java | 31 +- .../util/collection/ObjectIntMapping.java | 18 +- .../util/collection/ObjectIntMappingFactory.java | 29 +- .../apache/hugegraph/variables/HugeVariables.java | 33 +- .../org/apache/hugegraph/version/CoreVersion.java | 18 +- ...g.apache.tinkerpop.gremlin.jsr223.GremlinPlugin | 18 +- .../src/main/resources/hugegraph.properties | 18 +- .../src/main/resources/proto/raft.proto | 18 +- hugegraph-server/hugegraph-dist/docker/README.md | 2 +- .../hugegraph-dist/docker/docker-entrypoint.sh | 18 +- .../docker/scripts/detect-storage.groovy | 18 +- .../docker/scripts/remote-connect.groovy | 18 +- .../hugegraph-dist/download_keystore.sh | 18 +- .../hugegraph-dist/download_swagger_ui.sh | 18 +- hugegraph-server/hugegraph-dist/pom.xml | 18 +- .../hugegraph-dist/scripts/apache-release.sh | 18 +- .../scripts/dependency/check_dependencies.sh | 18 +- .../dependency/regenerate_known_dependencies.sh | 18 +- .../src/assembly/descriptor/assembly.xml | 18 +- .../hugegraph-dist/src/assembly/jenkins/build.sh | 18 +- .../hugegraph-dist/src/assembly/jenkins/config.sh | 18 +- .../hugegraph-dist/src/assembly/jenkins/deploy.sh | 18 +- .../hugegraph-dist/src/assembly/jenkins/jenkins.sh | 19 +- .../hugegraph-dist/src/assembly/jenkins/publish.sh | 18 +- .../hugegraph-dist/src/assembly/jenkins/test.sh | 18 +- .../src/assembly/static/bin/checksocket.sh | 21 +- .../src/assembly/static/bin/dump-conf.sh | 18 +- .../src/assembly/static/bin/dump-store.sh | 18 +- .../src/assembly/static/bin/enable-auth.sh | 18 +- .../src/assembly/static/bin/gremlin-console.sh | 18 +- .../src/assembly/static/bin/hugegraph | 18 +- .../src/assembly/static/bin/hugegraph-server.sh | 18 +- .../src/assembly/static/bin/init-store.sh | 18 +- .../src/assembly/static/bin/install.sh | 22 +- .../src/assembly/static/bin/monitor-hugegraph.sh | 18 +- .../src/assembly/static/bin/raft-tools.sh | 18 +- .../src/assembly/static/bin/start-hugegraph.sh | 18 +- .../src/assembly/static/bin/start-monitor.sh | 18 +- .../src/assembly/static/bin/stop-hugegraph.sh | 18 +- .../src/assembly/static/bin/stop-monitor.sh | 18 +- .../hugegraph-dist/src/assembly/static/bin/util.sh | 18 +- .../src/assembly/static/bin/wait-storage.sh | 18 +- .../static/conf/graphs/hugegraph.properties | 11 + .../src/assembly/static/conf/gremlin-server.yaml | 50 +-- .../src/assembly/static/conf/log4j2.xml | 44 +- .../src/assembly/static/conf/remote-objects.yaml | 4 +- .../assembly/static/scripts/empty-sample.groovy | 18 +- .../src/assembly/static/scripts/example.groovy | 18 +- .../src/assembly/travis/build-report.sh | 18 +- .../travis/conf-raft1/graphs/hugegraph.properties | 18 +- .../assembly/travis/conf-raft1/gremlin-server.yaml | 40 +- .../travis/conf-raft1/rest-server.properties | 18 +- .../travis/conf-raft2/graphs/hugegraph.properties | 18 +- .../assembly/travis/conf-raft2/gremlin-server.yaml | 40 +- .../travis/conf-raft2/rest-server.properties | 18 +- .../travis/conf-raft3/graphs/hugegraph.properties | 18 +- .../assembly/travis/conf-raft3/gremlin-server.yaml | 40 +- .../travis/conf-raft3/rest-server.properties | 18 +- .../src/assembly/travis/hbase-site.xml | 18 +- .../src/assembly/travis/install-backend.sh | 18 +- .../src/assembly/travis/install-cassandra.sh | 18 +- .../src/assembly/travis/install-hbase.sh | 18 +- .../assembly/travis/install-mysql-via-docker.sh | 18 +- .../src/assembly/travis/install-mysql.sh | 18 +- .../travis/install-postgresql-via-docker.sh | 18 +- .../src/assembly/travis/install-postgresql.sh | 18 +- .../src/assembly/travis/install-scylladb.sh | 18 +- .../hugegraph-dist/src/assembly/travis/maven.xml | 58 +-- .../src/assembly/travis/run-api-test-for-raft.sh | 18 +- .../src/assembly/travis/run-api-test.sh | 18 +- .../src/assembly/travis/run-core-test.sh | 18 +- .../src/assembly/travis/run-tinkerpop-test.sh | 18 +- .../src/assembly/travis/run-unit-test.sh | 18 +- .../src/assembly/travis/start-server.sh | 18 +- .../src/assembly/travis/stop-server.sh | 18 +- .../java/org/apache/hugegraph/cmd/ConfDumper.java | 25 +- .../java/org/apache/hugegraph/cmd/InitStore.java | 27 +- .../java/org/apache/hugegraph/cmd/StoreDumper.java | 18 +- .../org/apache/hugegraph/dist/DistOptions.java | 18 +- .../org/apache/hugegraph/dist/HugeGraphServer.java | 20 +- .../apache/hugegraph/dist/HugeGremlinServer.java | 25 +- .../org/apache/hugegraph/dist/HugeRestServer.java | 21 +- .../org/apache/hugegraph/dist/RegisterUtil.java | 55 ++- .../src/main/resources/backend.properties | 18 +- .../hugegraph-dist/src/main/resources/log4j2.xml | 44 +- hugegraph-server/hugegraph-example/pom.xml | 18 +- .../org/apache/hugegraph/example/Example1.java | 47 ++- .../org/apache/hugegraph/example/Example2.java | 61 ++- .../org/apache/hugegraph/example/Example3.java | 25 +- .../org/apache/hugegraph/example/ExampleUtil.java | 23 +- .../hugegraph/example/GraphOfTheMoviesExample.java | 152 +++---- .../org/apache/hugegraph/example/PerfExample1.java | 24 +- .../org/apache/hugegraph/example/PerfExample2.java | 24 +- .../org/apache/hugegraph/example/PerfExample3.java | 25 +- .../org/apache/hugegraph/example/PerfExample4.java | 24 +- .../apache/hugegraph/example/PerfExampleBase.java | 25 +- .../org/apache/hugegraph/example/TaskExample.java | 21 +- .../hugegraph/example/ThreadRangePerfTest.java | 21 +- .../src/main/resources/hugegraph.properties | 18 +- .../src/main/resources/log4j2.xml | 38 +- hugegraph-server/hugegraph-hbase/pom.xml | 18 +- .../backend/store/hbase/HbaseFeatures.java | 18 +- .../backend/store/hbase/HbaseMetrics.java | 28 +- .../backend/store/hbase/HbaseOptions.java | 20 +- .../backend/store/hbase/HbaseSerializer.java | 23 +- .../backend/store/hbase/HbaseSessions.java | 38 +- .../hugegraph/backend/store/hbase/HbaseStore.java | 82 ++-- .../backend/store/hbase/HbaseStoreProvider.java | 18 +- .../hugegraph/backend/store/hbase/HbaseTable.java | 34 +- .../hugegraph/backend/store/hbase/HbaseTables.java | 21 +- .../store/hstore/HstoreNodePartitionerImpl.java | 279 ------------- .../backend/store/hstore/HstoreOptions.java | 18 - .../backend/store/hstore/HstoreSessionsImpl.java | 11 +- hugegraph-server/hugegraph-mysql/pom.xml | 18 +- .../backend/store/mysql/MysqlBackendEntry.java | 18 +- .../backend/store/mysql/MysqlEntryIterator.java | 22 +- .../backend/store/mysql/MysqlFeatures.java | 18 +- .../backend/store/mysql/MysqlMetrics.java | 19 +- .../backend/store/mysql/MysqlOptions.java | 24 +- .../backend/store/mysql/MysqlSerializer.java | 21 +- .../backend/store/mysql/MysqlSessions.java | 38 +- .../hugegraph/backend/store/mysql/MysqlStore.java | 31 +- .../backend/store/mysql/MysqlStoreProvider.java | 18 +- .../hugegraph/backend/store/mysql/MysqlTable.java | 42 +- .../hugegraph/backend/store/mysql/MysqlTables.java | 41 +- .../hugegraph/backend/store/mysql/MysqlUtil.java | 18 +- .../backend/store/mysql/ResultSetWrapper.java | 18 +- .../backend/store/mysql/WhereBuilder.java | 52 ++- hugegraph-server/hugegraph-palo/pom.xml | 18 +- .../hugegraph/backend/store/palo/PaloFeatures.java | 18 +- .../hugegraph/backend/store/palo/PaloFile.java | 20 +- .../backend/store/palo/PaloHttpClient.java | 18 +- .../hugegraph/backend/store/palo/PaloLoadInfo.java | 18 +- .../hugegraph/backend/store/palo/PaloOptions.java | 18 +- .../backend/store/palo/PaloSerializer.java | 18 +- .../hugegraph/backend/store/palo/PaloSessions.java | 24 +- .../hugegraph/backend/store/palo/PaloStore.java | 21 +- .../backend/store/palo/PaloStoreProvider.java | 22 +- .../hugegraph/backend/store/palo/PaloTable.java | 23 +- .../hugegraph/backend/store/palo/PaloTables.java | 30 +- hugegraph-server/hugegraph-postgresql/pom.xml | 18 +- .../store/postgresql/PostgresqlOptions.java | 18 +- .../store/postgresql/PostgresqlSerializer.java | 27 +- .../store/postgresql/PostgresqlSessions.java | 52 +-- .../backend/store/postgresql/PostgresqlStore.java | 18 +- .../store/postgresql/PostgresqlStoreProvider.java | 27 +- .../backend/store/postgresql/PostgresqlTable.java | 24 +- .../backend/store/postgresql/PostgresqlTables.java | 52 +-- hugegraph-server/hugegraph-rocksdb/pom.xml | 18 +- .../backend/store/rocksdb/OpenedRocksDB.java | 18 +- .../backend/store/rocksdb/RocksDBFeatures.java | 18 +- .../backend/store/rocksdb/RocksDBIngester.java | 18 +- .../backend/store/rocksdb/RocksDBIteratorPool.java | 18 +- .../backend/store/rocksdb/RocksDBMetrics.java | 18 +- .../backend/store/rocksdb/RocksDBOptions.java | 18 +- .../backend/store/rocksdb/RocksDBSessions.java | 18 +- .../backend/store/rocksdb/RocksDBStdSessions.java | 54 +-- .../backend/store/rocksdb/RocksDBStore.java | 22 +- .../store/rocksdb/RocksDBStoreProvider.java | 18 +- .../backend/store/rocksdb/RocksDBTable.java | 20 +- .../backend/store/rocksdb/RocksDBTables.java | 18 +- .../store/rocksdbsst/RocksDBSstSessions.java | 24 +- .../backend/store/rocksdbsst/RocksDBSstStore.java | 20 +- .../store/rocksdbsst/RocksDBSstStoreProvider.java | 18 +- hugegraph-server/hugegraph-scylladb/pom.xml | 18 +- .../backend/store/scylladb/ScyllaDBFeatures.java | 18 +- .../backend/store/scylladb/ScyllaDBMetrics.java | 19 +- .../store/scylladb/ScyllaDBStoreProvider.java | 27 +- .../store/scylladb/ScyllaDBTablesWithMV.java | 70 ++-- hugegraph-server/hugegraph-test/pom.xml | 20 +- .../org/apache/hugegraph/api/ApiTestSuite.java | 50 +-- .../org/apache/hugegraph/api/ArthasApiTest.java | 18 +- .../java/org/apache/hugegraph/api/BaseApiTest.java | 292 ++++++------- .../org/apache/hugegraph/api/CypherApiTest.java | 20 +- .../java/org/apache/hugegraph/api/EdgeApiTest.java | 194 ++++----- .../org/apache/hugegraph/api/EdgeLabelApiTest.java | 114 ++--- .../org/apache/hugegraph/api/GremlinApiTest.java | 211 +++++----- .../apache/hugegraph/api/IndexLabelApiTest.java | 120 +++--- .../org/apache/hugegraph/api/LoginApiTest.java | 27 +- .../org/apache/hugegraph/api/MetricsApiTest.java | 18 +- .../org/apache/hugegraph/api/ProjectApiTest.java | 24 +- .../apache/hugegraph/api/PropertyKeyApiTest.java | 58 +-- .../org/apache/hugegraph/api/SchemaApiTest.java | 18 +- .../java/org/apache/hugegraph/api/TaskApiTest.java | 28 +- .../java/org/apache/hugegraph/api/UserApiTest.java | 28 +- .../org/apache/hugegraph/api/VertexApiTest.java | 66 +-- .../apache/hugegraph/api/VertexLabelApiTest.java | 90 ++-- .../api/traversers/AdamicAdarAPITest.java | 24 +- .../api/traversers/AllShortestPathsApiTest.java | 20 +- .../hugegraph/api/traversers/CountApiTest.java | 24 +- .../api/traversers/CrosspointsApiTest.java | 27 +- .../traversers/CustomizedCrosspointsApiTest.java | 22 +- .../hugegraph/api/traversers/EdgesApiTest.java | 27 +- .../api/traversers/FusiformSimilarityApiTest.java | 22 +- .../api/traversers/JaccardSimilarityApiTest.java | 26 +- .../hugegraph/api/traversers/KneighborApiTest.java | 18 +- .../hugegraph/api/traversers/KoutApiTest.java | 18 +- .../traversers/MultiNodeShortestPathApiTest.java | 22 +- .../api/traversers/NeighborRankApiTest.java | 22 +- .../hugegraph/api/traversers/PathsApiTest.java | 24 +- .../api/traversers/PersonalRankApiTest.java | 22 +- .../hugegraph/api/traversers/RaysApiTest.java | 18 +- .../api/traversers/ResourceAllocationAPITest.java | 24 +- .../hugegraph/api/traversers/RingsApiTest.java | 23 +- .../api/traversers/SameNeighborsApiTest.java | 18 +- .../api/traversers/ShortestPathApiTest.java | 23 +- .../SingleSourceShortestPathApiTest.java | 18 +- .../api/traversers/TemplatePathsApiTest.java | 23 +- .../api/traversers/TraversersApiTestSuite.java | 63 +-- .../traversers/WeightedShortestPathApiTest.java | 23 +- .../java/org/apache/hugegraph/core/AuthTest.java | 118 +++--- .../org/apache/hugegraph/core/BaseCoreTest.java | 18 +- .../org/apache/hugegraph/core/CoreTestSuite.java | 45 +- .../org/apache/hugegraph/core/EdgeCoreTest.java | 337 +++++++-------- .../apache/hugegraph/core/EdgeLabelCoreTest.java | 66 +-- .../apache/hugegraph/core/IndexLabelCoreTest.java | 90 ++-- .../org/apache/hugegraph/core/MultiGraphsTest.java | 18 +- .../apache/hugegraph/core/PropertyCoreTest.java | 40 +- .../apache/hugegraph/core/PropertyKeyCoreTest.java | 30 +- .../org/apache/hugegraph/core/RamTableTest.java | 49 ++- .../org/apache/hugegraph/core/RestoreCoreTest.java | 145 ++++--- .../core/RoleElectionStateMachineTest.java | 20 +- .../org/apache/hugegraph/core/SchemaCoreTest.java | 23 +- .../org/apache/hugegraph/core/TaskCoreTest.java | 175 ++++---- .../org/apache/hugegraph/core/VertexCoreTest.java | 410 +++++++++--------- .../apache/hugegraph/core/VertexLabelCoreTest.java | 58 +-- .../org/apache/hugegraph/testutil/FakeObjects.java | 21 +- .../java/org/apache/hugegraph/testutil/Utils.java | 25 +- .../hugegraph/tinkerpop/ProcessBasicSuite.java | 286 ++++++------- .../hugegraph/tinkerpop/ProcessStandardTest.java | 19 +- .../tinkerpop/ProcessTestGraphProvider.java | 18 +- .../hugegraph/tinkerpop/StructureBasicSuite.java | 79 ++-- .../hugegraph/tinkerpop/StructureStandardTest.java | 19 +- .../tinkerpop/StructureTestGraphProvider.java | 18 +- .../org/apache/hugegraph/tinkerpop/TestGraph.java | 23 +- .../hugegraph/tinkerpop/TestGraphFactory.java | 20 +- .../hugegraph/tinkerpop/TestGraphProvider.java | 68 +-- .../tinkerpop/tests/HugeGraphWriteTest.java | 29 +- .../org/apache/hugegraph/unit/BaseUnitTest.java | 25 +- .../org/apache/hugegraph/unit/FakeObjects.java | 27 +- .../org/apache/hugegraph/unit/UnitTestSuite.java | 155 +++---- .../hugegraph/unit/cache/CacheManagerTest.java | 38 +- .../org/apache/hugegraph/unit/cache/CacheTest.java | 34 +- .../unit/cache/CachedGraphTransactionTest.java | 27 +- .../unit/cache/CachedSchemaTransactionTest.java | 26 +- .../apache/hugegraph/unit/cache/RamTableTest.java | 27 +- .../hugegraph/unit/cassandra/CassandraTest.java | 38 +- .../apache/hugegraph/unit/core/AnalyzerTest.java | 29 +- .../hugegraph/unit/core/BackendMutationTest.java | 25 +- .../hugegraph/unit/core/BackendStoreInfoTest.java | 25 +- .../unit/core/ConditionQueryFlattenTest.java | 26 +- .../apache/hugegraph/unit/core/ConditionTest.java | 22 +- .../apache/hugegraph/unit/core/DataTypeTest.java | 23 +- .../apache/hugegraph/unit/core/DirectionsTest.java | 27 +- .../apache/hugegraph/unit/core/ExceptionTest.java | 22 +- .../apache/hugegraph/unit/core/LocksTableTest.java | 28 +- .../apache/hugegraph/unit/core/PageStateTest.java | 21 +- .../org/apache/hugegraph/unit/core/QueryTest.java | 22 +- .../org/apache/hugegraph/unit/core/RangeTest.java | 29 +- .../hugegraph/unit/core/RolePermissionTest.java | 64 +-- .../apache/hugegraph/unit/core/RowLockTest.java | 29 +- .../hugegraph/unit/core/SecurityManagerTest.java | 32 +- .../apache/hugegraph/unit/core/SerialEnumTest.java | 21 +- .../hugegraph/unit/core/SystemSchemaStoreTest.java | 23 +- .../hugegraph/unit/core/TraversalUtilTest.java | 37 +- .../org/apache/hugegraph/unit/id/EdgeIdTest.java | 28 +- .../java/org/apache/hugegraph/unit/id/IdTest.java | 60 ++- .../org/apache/hugegraph/unit/id/IdUtilTest.java | 23 +- .../hugegraph/unit/id/SplicingIdGeneratorTest.java | 34 +- .../apache/hugegraph/unit/mysql/MysqlUtilTest.java | 21 +- .../hugegraph/unit/mysql/WhereBuilderTest.java | 22 +- .../unit/rocksdb/BaseRocksDBUnitTest.java | 18 +- .../unit/rocksdb/RocksDBCountersTest.java | 18 +- .../hugegraph/unit/rocksdb/RocksDBPerfTest.java | 22 +- .../hugegraph/unit/rocksdb/RocksDBSessionTest.java | 41 +- .../unit/rocksdb/RocksDBSessionsTest.java | 18 +- .../unit/serializer/BinaryBackendEntryTest.java | 18 +- .../serializer/BinaryScatterSerializerTest.java | 18 +- .../unit/serializer/BinarySerializerTest.java | 18 +- .../hugegraph/unit/serializer/BytesBufferTest.java | 28 +- .../unit/serializer/SerializerFactoryTest.java | 23 +- .../unit/serializer/StoreSerializerTest.java | 25 +- .../unit/serializer/TableBackendEntryTest.java | 30 +- .../unit/serializer/TextBackendEntryTest.java | 22 +- .../hugegraph/unit/store/RamIntObjectMapTest.java | 18 +- .../hugegraph/unit/util/CompressUtilTest.java | 24 +- .../apache/hugegraph/unit/util/JsonUtilTest.java | 51 +-- .../hugegraph/unit/util/RateLimiterTest.java | 23 +- .../hugegraph/unit/util/StringEncodingTest.java | 31 +- .../apache/hugegraph/unit/util/VersionTest.java | 23 +- .../util/collection/CollectionFactoryTest.java | 30 +- .../hugegraph/unit/util/collection/IdSetTest.java | 32 +- .../unit/util/collection/Int2IntsMapTest.java | 65 ++- .../hugegraph/unit/util/collection/IntMapTest.java | 69 ++-- .../hugegraph/unit/util/collection/IntSetTest.java | 29 +- .../unit/util/collection/ObjectIntMappingTest.java | 27 +- .../src/main/resources/hugegraph.properties | 18 +- .../hugegraph-test/src/main/resources/log4j2.xml | 44 +- .../hugegraph/benchmark/BenchmarkConstants.java | 18 +- .../apache/hugegraph/benchmark/SimpleRandom.java | 18 +- .../map/MapRandomGetPutThroughputTest.java | 26 +- hugegraph-server/pom.xml | 18 +- hugegraph-store/build-change.sh | 35 -- hugegraph-store/build-pre.sh | 105 ----- hugegraph-store/build.sh | 33 -- hugegraph-store/ci.yml | 43 -- 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 | 18 +- .../org/apache/hugegraph/store/cli/AppConfig.java | 18 +- .../store/cli/StoreConsoleApplication.java | 18 +- .../hugegraph/store/cli/loader/HgThread2DB.java | 20 +- .../hugegraph/store/cli/scan/GrpcShardScanner.java | 18 +- .../hugegraph/store/cli/scan/HgStoreCommitter.java | 18 +- .../hugegraph/store/cli/scan/HgStoreScanner.java | 18 +- .../apache/hugegraph/store/cli/util/HgCliUtil.java | 18 +- .../apache/hugegraph/store/cli/util/HgMetricX.java | 18 +- .../src/main/resources/hg-store-client.properties | 21 +- .../hg-store-cli/src/main/resources/log4j2.xml | 18 +- hugegraph-store/hg-store-client/deploy-snapshot.sh | 23 -- hugegraph-store/hg-store-client/pom.xml | 18 +- .../java/org/apache/hugegraph/store/HgKvEntry.java | 18 +- .../org/apache/hugegraph/store/HgKvIterator.java | 18 +- .../hugegraph/store/HgKvOrderedIterator.java | 18 +- .../apache/hugegraph/store/HgKvPagingIterator.java | 18 +- .../java/org/apache/hugegraph/store/HgKvStore.java | 18 +- .../org/apache/hugegraph/store/HgOwnerKey.java | 18 +- .../org/apache/hugegraph/store/HgPageSize.java | 18 +- .../java/org/apache/hugegraph/store/HgPrivate.java | 18 +- .../org/apache/hugegraph/store/HgScanQuery.java | 18 +- .../org/apache/hugegraph/store/HgSeekAble.java | 18 +- .../apache/hugegraph/store/HgSessionManager.java | 18 +- .../apache/hugegraph/store/HgSessionProvider.java | 18 +- .../org/apache/hugegraph/store/HgStoreClient.java | 18 +- .../org/apache/hugegraph/store/HgStoreSession.java | 18 +- .../org/apache/hugegraph/store/HgTkvEntry.java | 18 +- .../org/apache/hugegraph/store/HgTokvEntry.java | 18 +- .../hugegraph/store/client/HgNodePartition.java | 18 +- .../store/client/HgNodePartitionerBuilder.java | 18 +- .../apache/hugegraph/store/client/HgPrivate.java | 18 +- .../apache/hugegraph/store/client/HgStoreNode.java | 20 +- .../hugegraph/store/client/HgStoreNodeBuilder.java | 18 +- .../store/client/HgStoreNodeCandidates.java | 18 +- .../hugegraph/store/client/HgStoreNodeManager.java | 18 +- .../store/client/HgStoreNodeNotifier.java | 18 +- .../store/client/HgStoreNodePartitioner.java | 18 +- .../store/client/HgStoreNodePartitionerImpl.java | 18 +- .../store/client/HgStoreNodeProvider.java | 18 +- .../hugegraph/store/client/HgStoreNodeSession.java | 18 +- .../hugegraph/store/client/HgStoreNotice.java | 18 +- .../hugegraph/store/client/HgStoreService.java | 18 +- .../store/client/HgStoreSessionProvider.java | 18 +- .../hugegraph/store/client/HgTkvEntryImpl.java | 18 +- .../hugegraph/store/client/HgTokvEntryImpl.java | 18 +- .../store/client/MultiNodeSessionFactory.java | 18 +- .../org/apache/hugegraph/store/client/NodeTkv.java | 18 +- .../hugegraph/store/client/NodeTxExecutor.java | 18 +- .../hugegraph/store/client/NodeTxSessionProxy.java | 18 +- .../hugegraph/store/client/SequencedIterator.java | 18 +- .../store/client/ShiftWorkIteratorProxy.java | 18 +- .../store/client/TopWorkIteratorProxy.java | 18 +- .../store/client/grpc/AbstractGrpcClient.java | 18 +- .../store/client/grpc/GrpcKvEntryImpl.java | 20 +- .../store/client/grpc/GrpcKvIteratorImpl.java | 18 +- .../store/client/grpc/GrpcNodeHealthyClient.java | 18 +- .../store/client/grpc/GrpcStoreNodeBuilder.java | 18 +- .../store/client/grpc/GrpcStoreNodeImpl.java | 18 +- .../client/grpc/GrpcStoreNodeSessionImpl.java | 18 +- .../store/client/grpc/GrpcStoreSessionClient.java | 18 +- .../store/client/grpc/GrpcStoreStateClient.java | 18 +- .../store/client/grpc/GrpcStoreStreamClient.java | 18 +- .../hugegraph/store/client/grpc/GrpcUtil.java | 18 +- .../store/client/grpc/KvBatchOneShotScanner.java | 20 +- .../store/client/grpc/KvBatchScanner.java | 18 +- .../store/client/grpc/KvBatchScanner5.java | 20 +- .../store/client/grpc/KvBatchScannerMerger.java | 18 +- .../hugegraph/store/client/grpc/KvBatchUtil.java | 20 +- .../store/client/grpc/KvCloseableIterator.java | 18 +- .../store/client/grpc/KvListIterator.java | 18 +- .../store/client/grpc/KvOneShotScanner.java | 20 +- .../hugegraph/store/client/grpc/KvPageScanner.java | 24 +- .../store/client/grpc/NotifyingExecutor.java | 18 +- .../hugegraph/store/client/grpc/ScanUtil.java | 18 +- .../store/client/grpc/SeekAbleIterator.java | 20 +- .../store/client/grpc/SwitchingExecutor.java | 18 +- .../hugegraph/store/client/type/HgNodeStatus.java | 18 +- .../store/client/type/HgStoreClientException.java | 18 +- .../apache/hugegraph/store/client/util/Base58.java | 18 +- .../hugegraph/store/client/util/ExecutorPool.java | 18 +- .../hugegraph/store/client/util/HgAssert.java | 20 +- .../hugegraph/store/client/util/HgBufferProxy.java | 18 +- .../store/client/util/HgStoreClientConfig.java | 18 +- .../store/client/util/HgStoreClientConst.java | 18 +- .../store/client/util/HgStoreClientUtil.java | 18 +- .../apache/hugegraph/store/client/util/HgUuid.java | 18 +- .../hugegraph/store/client/util/MetricX.java | 18 +- .../hugegraph/store/client/util/PropertyUtil.java | 18 +- .../src/main/resources/hg-store-client.properties | 21 +- .../hg-store-client/src/main/resources/log4j2.xml | 18 +- hugegraph-store/hg-store-common/mvnw | 310 -------------- hugegraph-store/hg-store-common/mvnw.cmd | 182 -------- hugegraph-store/hg-store-common/pom.xml | 18 +- .../store/buffer/ByteBufferAllocator.java | 18 +- .../hugegraph/store/buffer/KVByteBuffer.java | 18 +- .../java/org/apache/hugegraph/store/term/Bits.java | 18 +- .../org/apache/hugegraph/store/term/HgPair.java | 20 +- .../org/apache/hugegraph/store/term/HgTriple.java | 18 +- hugegraph-store/hg-store-core/build.sh | 32 -- hugegraph-store/hg-store-core/pom.xml | 18 +- .../apache/hugegraph/store/HeartbeatService.java | 18 +- .../org/apache/hugegraph/store/HgStoreEngine.java | 18 +- .../hugegraph/store/HgStoreStateListener.java | 18 +- .../apache/hugegraph/store/PartitionEngine.java | 18 +- .../store/PartitionInstructionProcessor.java | 18 +- .../hugegraph/store/PartitionStateListener.java | 18 +- .../store/business/AbstractSelectIterator.java | 18 +- .../hugegraph/store/business/BusinessHandler.java | 18 +- .../store/business/BusinessHandlerImpl.java | 18 +- .../apache/hugegraph/store/business/DataMover.java | 18 +- .../hugegraph/store/business/DefaultDataMover.java | 18 +- .../hugegraph/store/business/FilterIterator.java | 18 +- .../store/business/GraphStoreIterator.java | 18 +- .../hugegraph/store/business/InnerKeyCreator.java | 18 +- .../hugegraph/store/business/InnerKeyFilter.java | 18 +- .../store/business/MultiPartitionIterator.java | 18 +- .../hugegraph/store/business/SelectIterator.java | 18 +- .../hugegraph/store/cmd/BatchPutRequest.java | 18 +- .../hugegraph/store/cmd/BatchPutResponse.java | 18 +- .../hugegraph/store/cmd/CleanDataRequest.java | 18 +- .../hugegraph/store/cmd/CleanDataResponse.java | 18 +- .../hugegraph/store/cmd/CreateRaftRequest.java | 18 +- .../hugegraph/store/cmd/CreateRaftResponse.java | 18 +- .../hugegraph/store/cmd/DbCompactionRequest.java | 18 +- .../hugegraph/store/cmd/DbCompactionResponse.java | 20 +- .../hugegraph/store/cmd/DestroyRaftRequest.java | 18 +- .../hugegraph/store/cmd/DestroyRaftResponse.java | 18 +- .../hugegraph/store/cmd/FutureClosureAdapter.java | 18 +- .../hugegraph/store/cmd/GetStoreInfoRequest.java | 18 +- .../hugegraph/store/cmd/GetStoreInfoResponse.java | 18 +- .../org/apache/hugegraph/store/cmd/HgCmdBase.java | 18 +- .../apache/hugegraph/store/cmd/HgCmdClient.java | 18 +- .../apache/hugegraph/store/cmd/HgCmdProcessor.java | 18 +- .../store/cmd/UpdatePartitionRequest.java | 18 +- .../store/cmd/UpdatePartitionResponse.java | 18 +- .../hugegraph/store/meta/DeletedFileManager.java | 18 +- .../org/apache/hugegraph/store/meta/Graph.java | 18 +- .../hugegraph/store/meta/GraphIdManager.java | 20 +- .../apache/hugegraph/store/meta/GraphManager.java | 18 +- .../hugegraph/store/meta/MetadataKeyHelper.java | 18 +- .../org/apache/hugegraph/store/meta/Partition.java | 18 +- .../hugegraph/store/meta/PartitionManager.java | 18 +- .../apache/hugegraph/store/meta/PartitionRole.java | 18 +- .../hugegraph/store/meta/PartitionStats.java | 18 +- .../org/apache/hugegraph/store/meta/Shard.java | 18 +- .../apache/hugegraph/store/meta/ShardGroup.java | 18 +- .../org/apache/hugegraph/store/meta/Store.java | 18 +- .../apache/hugegraph/store/meta/StoreMetadata.java | 18 +- .../apache/hugegraph/store/meta/TaskManager.java | 18 +- .../store/meta/asynctask/AbstractAsyncTask.java | 18 +- .../hugegraph/store/meta/asynctask/AsyncTask.java | 18 +- .../store/meta/asynctask/AsyncTaskState.java | 18 +- .../hugegraph/store/meta/asynctask/CleanTask.java | 18 +- .../store/meta/base/DBSessionBuilder.java | 18 +- .../hugegraph/store/meta/base/GlobalMetaStore.java | 18 +- .../hugegraph/store/meta/base/MetaStoreBase.java | 18 +- .../store/meta/base/PartitionMetaStore.java | 18 +- .../hugegraph/store/metric/HgMetricService.java | 18 +- .../hugegraph/store/metric/HgStoreMetric.java | 18 +- .../store/metric/SystemMetricService.java | 18 +- .../store/options/HgStoreEngineOptions.java | 18 +- .../hugegraph/store/options/MetadataOptions.java | 18 +- .../store/options/PartitionEngineOptions.java | 18 +- .../store/options/RaftRocksdbOptions.java | 18 +- .../hugegraph/store/pd/DefaultPdProvider.java | 18 +- .../hugegraph/store/pd/FakePdServiceProvider.java | 18 +- .../store/pd/PartitionInstructionListener.java | 18 +- .../org/apache/hugegraph/store/pd/PdProvider.java | 18 +- .../hugegraph/store/raft/HgStoreStateMachine.java | 18 +- .../apache/hugegraph/store/raft/RaftClosure.java | 18 +- .../apache/hugegraph/store/raft/RaftOperation.java | 18 +- .../hugegraph/store/raft/RaftStateListener.java | 18 +- .../hugegraph/store/raft/RaftTaskHandler.java | 18 +- .../hugegraph/store/raft/util/RaftUtils.java | 18 +- .../store/snapshot/HgSnapshotHandler.java | 18 +- .../org/apache/hugegraph/store/util/Asserts.java | 20 +- .../hugegraph/store/util/CopyOnWriteCache.java | 20 +- .../apache/hugegraph/store/util/FutureClosure.java | 18 +- .../apache/hugegraph/store/util/HgRaftError.java | 18 +- .../apache/hugegraph/store/util/HgStoreConst.java | 18 +- .../hugegraph/store/util/HgStoreException.java | 18 +- .../org/apache/hugegraph/store/util/IpUtil.java | 18 +- .../org/apache/hugegraph/store/util/Lifecycle.java | 18 +- .../hugegraph/store/util/ManualResetEvent.java | 18 +- .../store/util/PartitionMetaStoreWrapper.java | 18 +- .../hugegraph/store/util/UnsafeUtf8Util.java | 18 +- .../apache/hugegraph/store/util/UnsafeUtil.java | 18 +- .../org/apache/hugegraph/store/util/Version.java | 18 +- .../org/apache/hugegraph/store/util/ZipUtils.java | 18 +- hugegraph-store/hg-store-dist/pom.xml | 18 +- .../src/assembly/descriptor/server-assembly.xml | 18 +- .../assembly/static/bin/restart-hugegraph-store.sh | 20 +- .../assembly/static/bin/start-hugegraph-store.sh | 18 +- .../assembly/static/bin/stop-hugegraph-store.sh | 18 +- .../hg-store-dist/src/assembly/static/bin/util.sh | 18 +- .../src/assembly/static/conf/log4j2.xml | 23 +- hugegraph-store/hg-store-grpc/build.sh | 26 -- hugegraph-store/hg-store-grpc/pom.xml | 18 +- .../store/grpc/stream/HgStoreStreamGrpc.java | 18 +- .../store/grpc/stream/HgStoreStreamProto.java | 18 +- .../hugegraph/store/grpc/stream/KvStream.java | 18 +- .../store/grpc/stream/KvStreamOrBuilder.java | 18 +- .../hugegraph/store/grpc/stream/store_stream.proto | 17 + .../hg-store-grpc/src/main/proto/graphpb.proto | 17 + .../hg-store-grpc/src/main/proto/healthy.proto | 19 +- .../src/main/proto/store_common.proto | 19 +- .../src/main/proto/store_session.proto | 17 + .../hg-store-grpc/src/main/proto/store_state.proto | 17 + .../src/main/proto/store_stream_meta.proto | 17 + hugegraph-store/hg-store-node/pom.xml | 18 +- .../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 | 18 +- .../hugegraph/store/node/AppShutdownHook.java | 18 +- .../hugegraph/store/node/StoreNodeApplication.java | 18 +- .../node/controller/HgStoreMetricsController.java | 18 +- .../node/controller/HgStoreStatusController.java | 18 +- .../store/node/controller/HgTestController.java | 18 +- .../hugegraph/store/node/controller/IndexAPI.java | 18 +- .../store/node/controller/PartitionAPI.java | 18 +- .../hugegraph/store/node/entry/RestResult.java | 18 +- .../store/node/grpc/BatchGrpcClosure.java | 20 +- .../store/node/grpc/BatchScanIterator.java | 18 +- .../hugegraph/store/node/grpc/EmptyIterator.java | 18 +- .../store/node/grpc/FusingScanIterator.java | 20 +- .../store/node/grpc/GRpcServerConfig.java | 18 +- .../hugegraph/store/node/grpc/GrpcClosure.java | 20 +- .../store/node/grpc/HgStoreNodeService.java | 18 +- .../store/node/grpc/HgStoreNodeState.java | 18 +- .../store/node/grpc/HgStoreSessionImpl.java | 18 +- .../store/node/grpc/HgStoreStateService.java | 18 +- .../store/node/grpc/HgStoreStateSubject.java | 18 +- .../store/node/grpc/HgStoreStreamImpl.java | 18 +- .../store/node/grpc/HgStoreWrapperEx.java | 18 +- .../store/node/grpc/ParallelScanIterator.java | 18 +- .../hugegraph/store/node/grpc/QueryCondition.java | 18 +- .../store/node/grpc/ScanBatchOneShotResponse.java | 20 +- .../store/node/grpc/ScanBatchResponse.java | 18 +- .../store/node/grpc/ScanBatchResponse3.java | 20 +- .../store/node/grpc/ScanBatchResponseFactory.java | 18 +- .../store/node/grpc/ScanOneShotResponse.java | 20 +- .../hugegraph/store/node/grpc/ScanQuery.java | 18 +- .../store/node/grpc/ScanQueryProducer.java | 18 +- .../store/node/grpc/ScanStreamResponse.java | 20 +- .../apache/hugegraph/store/node/grpc/ScanUtil.java | 20 +- .../store/node/grpc/scan/GraphStoreImpl.java | 18 +- .../store/node/grpc/scan/ScanResponseObserver.java | 18 +- .../store/node/listener/ContextClosedListener.java | 18 +- .../store/node/listener/PdConfigureListener.java | 20 +- .../hugegraph/store/node/metrics/DriveMetrics.java | 18 +- .../store/node/metrics/GRpcExMetrics.java | 18 +- .../hugegraph/store/node/metrics/JRaftMetrics.java | 18 +- .../store/node/metrics/MetricsConfig.java | 18 +- .../hugegraph/store/node/metrics/MetricsUtil.java | 18 +- .../hugegraph/store/node/metrics/ProcfsEntry.java | 11 +- .../store/node/metrics/ProcfsMetrics.java | 18 +- .../hugegraph/store/node/metrics/ProcfsReader.java | 11 +- .../hugegraph/store/node/metrics/ProcfsSmaps.java | 11 +- .../store/node/metrics/RocksDBMetrics.java | 18 +- .../store/node/metrics/RocksDBMetricsConst.java | 18 +- .../hugegraph/store/node/metrics/StoreMetrics.java | 18 +- .../store/node/metrics/SystemMetrics.java | 18 +- .../hugegraph/store/node/model/HgNodeStatus.java | 18 +- .../apache/hugegraph/store/node/util/Base58.java | 18 +- .../org/apache/hugegraph/store/node/util/Err.java | 18 +- .../apache/hugegraph/store/node/util/HgAssert.java | 20 +- .../hugegraph/store/node/util/HgBufferProxy.java | 18 +- .../hugegraph/store/node/util/HgChannel.java | 18 +- .../hugegraph/store/node/util/HgExecutorUtil.java | 18 +- .../apache/hugegraph/store/node/util/HgGrpc.java | 18 +- .../hugegraph/store/node/util/HgRegexUtil.java | 18 +- .../hugegraph/store/node/util/HgStoreConst.java | 18 +- .../hugegraph/store/node/util/HgStoreNodeUtil.java | 20 +- .../hugegraph/store/node/util/PropertyUtil.java | 18 +- .../apache/hugegraph/store/node/util/Result.java | 18 +- .../apache/hugegraph/store/node/util/TkEntry.java | 18 +- .../src/main/resources/log4j2-dev.xml | 18 +- .../hugegraph/store/boot/StoreNodeServer00.java | 20 +- .../hugegraph/store/boot/StoreNodeServer01.java | 20 +- .../hugegraph/store/boot/StoreNodeServer02.java | 20 +- .../hugegraph/store/boot/StoreNodeServer03.java | 20 +- .../hugegraph/store/boot/StoreNodeServer04.java | 20 +- .../hugegraph/store/boot/StoreNodeServer05.java | 20 +- .../hugegraph/store/boot/StoreNodeServer06.java | 20 +- .../store/node/HgStoreNodeServiceTest.java | 18 +- .../store/node/metrics/JraftMetricsTest.java | 18 +- .../src/test/resources/log4j2-dev.xml | 18 +- hugegraph-store/hg-store-rocksdb/pom.xml | 18 +- .../hugegraph/rocksdb/access/DBSnapshotMeta.java | 18 +- .../hugegraph/rocksdb/access/DBStoreException.java | 18 +- .../hugegraph/rocksdb/access/RocksDBFactory.java | 18 +- .../hugegraph/rocksdb/access/RocksDBOptions.java | 18 +- .../rocksdb/access/RocksDBScanIterator.java | 18 +- .../hugegraph/rocksdb/access/RocksDBSession.java | 18 +- .../hugegraph/rocksdb/access/ScanIterator.java | 18 +- .../hugegraph/rocksdb/access/SessionOperator.java | 18 +- .../rocksdb/access/SessionOperatorImpl.java | 18 +- .../hugegraph/rocksdb/access/util/Asserts.java | 20 +- .../hugegraph/rocksdb/access/util/CRC64.java | 18 +- .../hugegraph/rocksdb/access/util/ZipUtils.java | 18 +- .../rocksdb/access/RocksDBFactoryTest.java | 20 +- .../rocksdb/access/RocksDBSessionTest.java | 20 +- .../hugegraph/rocksdb/access/RocksdbDump.java | 18 +- .../rocksdb/access/SnapshotManagerTest.java | 18 +- .../src/test/resources/hugegraph-2.properties | 19 +- .../src/test/resources/hugegraph.properties | 19 +- .../hg-store-rocksdb/src/test/resources/log4j2.xml | 26 +- hugegraph-store/hg-store-test/pom.xml | 18 +- .../apache/hugegraph/store/HgBusinessImplTest.java | 18 +- .../store/HgSessionManagerOneRaftFakePDTest.java | 20 +- .../store/HgSessionManagerRaftFakePDTest.java | 20 +- .../store/HgSessionManagerRaftPDTest.java | 20 +- .../hugegraph/store/HgSessionManagerTest.java | 18 +- .../hugegraph/store/PartitionEngineTest.java | 18 +- .../org/apache/hugegraph/store/UnitTestBase.java | 18 +- .../hugegraph/store/client/BaseClientTest.java | 18 +- .../hugegraph/store/client/ChangeShardNumTest.java | 18 +- .../hugegraph/store/client/ClientSuiteTest.java | 18 +- .../apache/hugegraph/store/client/ClientTest.java | 18 +- .../hugegraph/store/client/HgAssertTest.java | 18 +- .../hugegraph/store/client/HgKvStoreTest.java | 18 +- .../apache/hugegraph/store/client/HgPairTest.java | 18 +- .../store/client/HgSessionManagerRaftPDTest.java | 18 +- .../hugegraph/store/client/HgStoreClientBase.java | 18 +- .../hugegraph/store/client/HgStoreClientTest.java | 18 +- .../store/client/HgStoreNodeSessionTest.java | 18 +- .../store/client/HgStoreNodeStateTest.java | 18 +- .../store/client/HgStoreNodeStreamTest.java | 18 +- .../store/client/graph/GraphStoreClientTest.java | 18 +- .../hugegraph/store/common/BaseCommonTest.java | 18 +- .../apache/hugegraph/store/common/BitsTest.java | 18 +- .../store/common/ByteBufferAllocatorTest.java | 18 +- .../hugegraph/store/common/CommonSuiteTest.java | 18 +- .../hugegraph/store/common/KVByteBufferTest.java | 18 +- .../apache/hugegraph/store/core/BaseCoreTest.java | 18 +- .../apache/hugegraph/store/core/CoreSuiteTest.java | 18 +- .../org/apache/hugegraph/store/core/CoreTest.java | 18 +- .../hugegraph/store/core/HgBusinessImplTest.java | 18 +- .../hugegraph/store/core/HgCmdClientTest.java | 18 +- .../hugegraph/store/core/MetricServiceTest.java | 18 +- .../hugegraph/store/core/StoreEngineTestBase.java | 18 +- .../store/core/raft/HgStoreStateMachineTest.java | 18 +- .../store/core/raft/MockStateMachine.java | 18 +- .../store/core/raft/RaftOperationTest.java | 18 +- .../hugegraph/store/core/raft/RaftUtilsTest.java | 18 +- .../store/core/snapshot/HgSnapshotHandlerTest.java | 18 +- .../store/core/store/HgStoreEngineTest.java | 18 +- .../store/core/store/PartitionEngineTest.java | 18 +- .../store/PartitionInstructionProcessorTest.java | 18 +- .../core/store/meta/MetadataKeyHelperTest.java | 18 +- .../core/store/meta/PartitionManagerTest.java | 18 +- .../store/core/store/meta/TaskManagerTest.java | 18 +- .../core/store/meta/asynctask/CleanTaskTest.java | 18 +- .../store/core/store/util/MiscUtilClassTest.java | 18 +- .../store/util/PartitionMetaStoreWrapperTest.java | 18 +- .../store/core/store/util/ZipUtilsTest.java | 18 +- .../hugegraph/store/meta/GraphIDManagerTest.java | 18 +- .../hugegraph/store/meta/GraphManagerTest.java | 18 +- .../hugegraph/store/raftcore/BytesCarrierTest.java | 18 +- .../hugegraph/store/raftcore/RaftSuiteTest.java | 18 +- .../store/raftcore/ZeroByteStringHelperTest.java | 18 +- .../hugegraph/store/rocksdb/BaseRocksDbTest.java | 18 +- .../store/rocksdb/RocksDBFactoryTest.java | 18 +- .../hugegraph/store/rocksdb/RocksDbSuiteTest.java | 18 +- .../hugegraph/store/service/BaseServerTest.java | 18 +- .../hugegraph/store/service/ServerSuiteTest.java | 18 +- .../hugegraph/store/service/SessionTest.java | 18 +- .../hugegraph/store/util/CopyOnWriteCacheTest.java | 18 +- .../hugegraph/store/util/FutureClosureTest.java | 18 +- .../hugegraph/store/util/HgStoreTestUtil.java | 18 +- .../apache/hugegraph/store/util/UnitTestBase.java | 18 +- .../hugegraph/store/util/UnsafeUtilTest.java | 18 +- .../hg-store-test/src/main/resources/log4j2.xml | 18 +- hugegraph-store/init.sh | 25 -- hugegraph-store/local-release.sh | 25 -- hugegraph-store/pom.xml | 20 +- hugegraph-store/run.sh | 22 - hugegraph-store/settings.xml | 133 ------ hugegraph-style.xml | 48 ++- pom.xml | 40 +- style/checkstyle.xml | 18 +- 1393 files changed, 17642 insertions(+), 18922 deletions(-)
