This is an automated email from the ASF dual-hosted git repository. jin pushed a commit to branch zy_dev in repository https://gitbox.apache.org/repos/asf/incubator-hugegraph.git
commit 674af2abdf509c908d245c4440031407f7275382 Merge: 6e365fb0e d34042034 Author: imbajin <[email protected]> AuthorDate: Fri Nov 25 14:23:39 2022 +0800 Merge branch 'master' into zy_dev .gitignore | 1 + hugegraph-api/pom.xml | 16 +- .../src/main/java/com/baidu/hugegraph/api/API.java | 195 - .../com/baidu/hugegraph/api/auth/AccessAPI.java | 215 - .../com/baidu/hugegraph/api/auth/BelongAPI.java | 206 - .../com/baidu/hugegraph/api/auth/GroupAPI.java | 183 - .../com/baidu/hugegraph/api/auth/LoginAPI.java | 161 - .../com/baidu/hugegraph/api/auth/ProjectAPI.java | 274 - .../com/baidu/hugegraph/api/auth/TargetAPI.java | 203 - .../java/com/baidu/hugegraph/api/auth/UserAPI.java | 234 - .../hugegraph/api/filter/AuthenticationFilter.java | 291 - .../hugegraph/api/filter/CompressInterceptor.java | 111 - .../api/filter/DecompressInterceptor.java | 58 - .../hugegraph/api/filter/ExceptionFilter.java | 288 - .../hugegraph/api/filter/LoadDetectFilter.java | 110 - .../hugegraph/api/filter/LoadReleaseFilter.java | 48 - .../baidu/hugegraph/api/filter/StatusFilter.java | 59 - .../com/baidu/hugegraph/api/graph/BatchAPI.java | 169 - .../com/baidu/hugegraph/api/graph/EdgeAPI.java | 574 -- .../com/baidu/hugegraph/api/graph/VertexAPI.java | 479 - .../com/baidu/hugegraph/api/gremlin/CypherAPI.java | 113 - .../baidu/hugegraph/api/gremlin/GremlinAPI.java | 87 - .../baidu/hugegraph/api/gremlin/GremlinClient.java | 78 - .../hugegraph/api/gremlin/GremlinQueryAPI.java | 109 - .../com/baidu/hugegraph/api/job/AlgorithmAPI.java | 84 - .../com/baidu/hugegraph/api/job/ComputerAPI.java | 87 - .../com/baidu/hugegraph/api/job/GremlinAPI.java | 210 - .../com/baidu/hugegraph/api/job/RebuildAPI.java | 98 - .../java/com/baidu/hugegraph/api/job/TaskAPI.java | 187 - .../baidu/hugegraph/api/metrics/MetricsAPI.java | 163 - .../com/baidu/hugegraph/api/profile/GraphsAPI.java | 287 - .../baidu/hugegraph/api/profile/ProfileAPI.java | 232 - .../baidu/hugegraph/api/profile/VersionAPI.java | 53 - .../java/com/baidu/hugegraph/api/raft/RaftAPI.java | 217 - .../baidu/hugegraph/api/schema/EdgeLabelAPI.java | 274 - .../baidu/hugegraph/api/schema/IndexLabelAPI.java | 294 - .../baidu/hugegraph/api/schema/PropertyKeyAPI.java | 274 - .../com/baidu/hugegraph/api/schema/SchemaAPI.java | 70 - .../baidu/hugegraph/api/schema/VertexLabelAPI.java | 266 - .../hugegraph/api/traversers/AdamicAdarAPI.java | 89 - .../api/traversers/AllShortestPathsAPI.java | 95 - .../baidu/hugegraph/api/traversers/CountAPI.java | 149 - .../hugegraph/api/traversers/CrosspointsAPI.java | 91 - .../api/traversers/CustomizedCrosspointsAPI.java | 200 - .../api/traversers/CustomizedPathsAPI.java | 201 - .../baidu/hugegraph/api/traversers/EdgesAPI.java | 126 - .../api/traversers/FusiformSimilarityAPI.java | 170 - .../api/traversers/JaccardSimilarityAPI.java | 147 - .../hugegraph/api/traversers/KneighborAPI.java | 191 - .../baidu/hugegraph/api/traversers/KoutAPI.java | 206 - .../api/traversers/MultiNodeShortestPathAPI.java | 128 - .../hugegraph/api/traversers/NeighborRankAPI.java | 154 - .../baidu/hugegraph/api/traversers/PathsAPI.java | 185 - .../hugegraph/api/traversers/PersonalRankAPI.java | 142 - .../baidu/hugegraph/api/traversers/RaysAPI.java | 89 - .../api/traversers/ResourceAllocationAPI.java | 90 - .../baidu/hugegraph/api/traversers/RingsAPI.java | 92 - .../hugegraph/api/traversers/SameNeighborsAPI.java | 84 - .../hugegraph/api/traversers/ShortestPathAPI.java | 96 - .../traversers/SingleSourceShortestPathAPI.java | 101 - .../hugegraph/api/traversers/TemplatePathsAPI.java | 168 - .../hugegraph/api/traversers/TraverserAPI.java | 63 - .../baidu/hugegraph/api/traversers/Vertices.java | 88 - .../hugegraph/api/traversers/VerticesAPI.java | 126 - .../api/traversers/WeightedShortestPathAPI.java | 104 - .../hugegraph/api/variables/VariablesAPI.java | 123 - .../baidu/hugegraph/auth/ConfigAuthenticator.java | 105 - .../baidu/hugegraph/auth/ContextGremlinServer.java | 168 - .../baidu/hugegraph/auth/HugeAuthenticator.java | 501 -- .../baidu/hugegraph/auth/HugeFactoryAuthProxy.java | 335 - .../baidu/hugegraph/auth/HugeGraphAuthProxy.java | 1882 ---- .../hugegraph/auth/StandardAuthenticator.java | 198 - .../hugegraph/auth/WsAndHttpBasicAuthHandler.java | 160 - .../com/baidu/hugegraph/config/ServerOptions.java | 269 - .../com/baidu/hugegraph/core/GraphManager.java | 594 -- .../java/com/baidu/hugegraph/define/Checkable.java | 29 - .../com/baidu/hugegraph/define/UpdateStrategy.java | 205 - .../java/com/baidu/hugegraph/define/WorkLoad.java | 51 - .../baidu/hugegraph/license/LicenseVerifier.java | 132 - .../hugegraph/license/LicenseVerifyManager.java | 251 - .../com/baidu/hugegraph/metrics/MetricsModule.java | 302 - .../com/baidu/hugegraph/metrics/MetricsUtil.java | 56 - .../baidu/hugegraph/metrics/ServerReporter.java | 115 - .../com/baidu/hugegraph/metrics/SystemMetrics.java | 140 - .../hugegraph/rpc/RpcClientProviderWithAuth.java | 46 - .../baidu/hugegraph/serializer/JsonSerializer.java | 326 - .../com/baidu/hugegraph/serializer/Serializer.java | 101 - .../baidu/hugegraph/server/ApplicationConfig.java | 196 - .../com/baidu/hugegraph/server/RestServer.java | 217 - .../com/baidu/hugegraph/version/ApiVersion.java | 131 - .../main/java/org/apache/hugegraph/api/API.java | 195 + .../org/apache/hugegraph/api/auth/AccessAPI.java | 215 + .../org/apache/hugegraph/api/auth/BelongAPI.java | 206 + .../org/apache/hugegraph/api/auth/GroupAPI.java | 183 + .../org/apache/hugegraph/api/auth/LoginAPI.java | 160 + .../org/apache/hugegraph/api/auth/ProjectAPI.java | 274 + .../org/apache/hugegraph/api/auth/TargetAPI.java | 203 + .../org/apache/hugegraph/api/auth/UserAPI.java | 234 + .../hugegraph/api/filter/AuthenticationFilter.java | 291 + .../hugegraph/api/filter/CompressInterceptor.java | 112 + .../api/filter/DecompressInterceptor.java | 58 + .../hugegraph/api/filter/ExceptionFilter.java | 288 + .../hugegraph/api/filter/LoadDetectFilter.java | 110 + .../hugegraph/api/filter/LoadReleaseFilter.java | 48 + .../apache/hugegraph/api/filter/StatusFilter.java | 59 + .../org/apache/hugegraph/api/graph/BatchAPI.java | 169 + .../org/apache/hugegraph/api/graph/EdgeAPI.java | 574 ++ .../org/apache/hugegraph/api/graph/VertexAPI.java | 479 + .../apache/hugegraph/api/gremlin/CypherAPI.java | 113 + .../apache/hugegraph/api/gremlin/GremlinAPI.java | 87 + .../hugegraph/api/gremlin/GremlinClient.java | 78 + .../hugegraph/api/gremlin/GremlinQueryAPI.java | 109 + .../org/apache/hugegraph/api/job/AlgorithmAPI.java | 84 + .../org/apache/hugegraph/api/job/ComputerAPI.java | 87 + .../org/apache/hugegraph/api/job/GremlinAPI.java | 210 + .../org/apache/hugegraph/api/job/RebuildAPI.java | 98 + .../java/org/apache/hugegraph/api/job/TaskAPI.java | 187 + .../apache/hugegraph/api/metrics/MetricsAPI.java | 163 + .../apache/hugegraph/api/profile/GraphsAPI.java | 287 + .../apache/hugegraph/api/profile/ProfileAPI.java | 232 + .../apache/hugegraph/api/profile/VersionAPI.java | 53 + .../org/apache/hugegraph/api/raft/RaftAPI.java | 217 + .../apache/hugegraph/api/schema/EdgeLabelAPI.java | 274 + .../apache/hugegraph/api/schema/IndexLabelAPI.java | 294 + .../hugegraph/api/schema/PropertyKeyAPI.java | 274 + .../org/apache/hugegraph/api/schema/SchemaAPI.java | 70 + .../hugegraph/api/schema/VertexLabelAPI.java | 266 + .../hugegraph/api/traversers/AdamicAdarAPI.java | 89 + .../api/traversers/AllShortestPathsAPI.java | 95 + .../apache/hugegraph/api/traversers/CountAPI.java | 149 + .../hugegraph/api/traversers/CrosspointsAPI.java | 91 + .../api/traversers/CustomizedCrosspointsAPI.java | 200 + .../api/traversers/CustomizedPathsAPI.java | 201 + .../apache/hugegraph/api/traversers/EdgesAPI.java | 126 + .../api/traversers/FusiformSimilarityAPI.java | 170 + .../api/traversers/JaccardSimilarityAPI.java | 147 + .../hugegraph/api/traversers/KneighborAPI.java | 191 + .../apache/hugegraph/api/traversers/KoutAPI.java | 206 + .../api/traversers/MultiNodeShortestPathAPI.java | 128 + .../hugegraph/api/traversers/NeighborRankAPI.java | 154 + .../apache/hugegraph/api/traversers/PathsAPI.java | 185 + .../hugegraph/api/traversers/PersonalRankAPI.java | 142 + .../apache/hugegraph/api/traversers/RaysAPI.java | 89 + .../api/traversers/ResourceAllocationAPI.java | 90 + .../apache/hugegraph/api/traversers/RingsAPI.java | 92 + .../hugegraph/api/traversers/SameNeighborsAPI.java | 84 + .../hugegraph/api/traversers/ShortestPathAPI.java | 96 + .../traversers/SingleSourceShortestPathAPI.java | 101 + .../hugegraph/api/traversers/TemplatePathsAPI.java | 168 + .../hugegraph/api/traversers/TraverserAPI.java | 63 + .../apache/hugegraph/api/traversers/Vertices.java | 88 + .../hugegraph/api/traversers/VerticesAPI.java | 126 + .../api/traversers/WeightedShortestPathAPI.java | 104 + .../hugegraph/api/variables/VariablesAPI.java | 123 + .../apache/hugegraph/auth/ConfigAuthenticator.java | 105 + .../hugegraph/auth/ContextGremlinServer.java | 168 + .../apache/hugegraph/auth/HugeAuthenticator.java | 501 ++ .../hugegraph/auth/HugeFactoryAuthProxy.java | 339 + .../apache/hugegraph/auth/HugeGraphAuthProxy.java | 1882 ++++ .../hugegraph/auth/StandardAuthenticator.java | 198 + .../hugegraph/auth/WsAndHttpBasicAuthHandler.java | 160 + .../org/apache/hugegraph/config/ServerOptions.java | 269 + .../org/apache/hugegraph/core/GraphManager.java | 594 ++ .../org/apache/hugegraph/define/Checkable.java | 29 + .../apache/hugegraph/define/UpdateStrategy.java | 205 + .../java/org/apache/hugegraph/define/WorkLoad.java | 51 + .../apache/hugegraph/license/LicenseVerifier.java | 132 + .../hugegraph/license/LicenseVerifyManager.java | 251 + .../apache/hugegraph/metrics/MetricsModule.java | 304 + .../org/apache/hugegraph/metrics/MetricsUtil.java | 56 + .../apache/hugegraph/metrics/ServerReporter.java | 115 + .../apache/hugegraph/metrics/SystemMetrics.java | 140 + .../hugegraph/rpc/RpcClientProviderWithAuth.java | 46 + .../hugegraph/serializer/JsonSerializer.java | 326 + .../apache/hugegraph/serializer/Serializer.java | 101 + .../apache/hugegraph/server/ApplicationConfig.java | 196 + .../org/apache/hugegraph/server/RestServer.java | 217 + .../org/apache/hugegraph/version/ApiVersion.java | 132 + hugegraph-cassandra/pom.xml | 13 +- .../store/cassandra/CassandraBackendEntry.java | 43 - .../store/cassandra/CassandraEntryIterator.java | 196 - .../backend/store/cassandra/CassandraFeatures.java | 134 - .../backend/store/cassandra/CassandraMetrics.java | 327 - .../backend/store/cassandra/CassandraOptions.java | 135 - .../store/cassandra/CassandraSerializer.java | 226 - .../store/cassandra/CassandraSessionPool.java | 276 - .../backend/store/cassandra/CassandraShard.java | 321 - .../backend/store/cassandra/CassandraStore.java | 825 -- .../store/cassandra/CassandraStoreProvider.java | 77 - .../backend/store/cassandra/CassandraTable.java | 683 -- .../backend/store/cassandra/CassandraTables.java | 996 --- .../datastax/driver/core/querybuilder/Clauses.java | 17 +- .../store/cassandra/CassandraBackendEntry.java | 43 + .../store/cassandra/CassandraEntryIterator.java | 197 + .../backend/store/cassandra/CassandraFeatures.java | 134 + .../backend/store/cassandra/CassandraMetrics.java | 326 + .../backend/store/cassandra/CassandraOptions.java | 135 + .../store/cassandra/CassandraSerializer.java | 226 + .../store/cassandra/CassandraSessionPool.java | 276 + .../backend/store/cassandra/CassandraShard.java | 318 + .../backend/store/cassandra/CassandraStore.java | 818 ++ .../store/cassandra/CassandraStoreProvider.java | 77 + .../backend/store/cassandra/CassandraTable.java | 682 ++ .../backend/store/cassandra/CassandraTables.java | 991 +++ hugegraph-core/pom.xml | 6 +- .../java/com/baidu/hugegraph/HugeException.java | 64 - .../main/java/com/baidu/hugegraph/HugeFactory.java | 171 - .../main/java/com/baidu/hugegraph/HugeGraph.java | 325 - .../java/com/baidu/hugegraph/HugeGraphParams.java | 95 - .../com/baidu/hugegraph/StandardHugeGraph.java | 1619 ---- .../com/baidu/hugegraph/analyzer/Analyzer.java | 27 - .../baidu/hugegraph/analyzer/AnalyzerFactory.java | 100 - .../com/baidu/hugegraph/analyzer/AnsjAnalyzer.java | 87 - .../baidu/hugegraph/analyzer/HanLPAnalyzer.java | 106 - .../com/baidu/hugegraph/analyzer/IKAnalyzer.java | 71 - .../baidu/hugegraph/analyzer/JcsegAnalyzer.java | 82 - .../baidu/hugegraph/analyzer/JiebaAnalyzer.java | 62 - .../baidu/hugegraph/analyzer/MMSeg4JAnalyzer.java | 91 - .../baidu/hugegraph/analyzer/SmartCNAnalyzer.java | 62 - .../com/baidu/hugegraph/auth/AuthConstant.java | 29 - .../java/com/baidu/hugegraph/auth/AuthManager.java | 131 - .../com/baidu/hugegraph/auth/EntityManager.java | 200 - .../java/com/baidu/hugegraph/auth/HugeAccess.java | 234 - .../java/com/baidu/hugegraph/auth/HugeBelong.java | 201 - .../java/com/baidu/hugegraph/auth/HugeGroup.java | 200 - .../com/baidu/hugegraph/auth/HugePermission.java | 67 - .../java/com/baidu/hugegraph/auth/HugeProject.java | 313 - .../com/baidu/hugegraph/auth/HugeResource.java | 356 - .../java/com/baidu/hugegraph/auth/HugeTarget.java | 263 - .../java/com/baidu/hugegraph/auth/HugeUser.java | 286 - .../baidu/hugegraph/auth/RelationshipManager.java | 243 - .../com/baidu/hugegraph/auth/ResourceObject.java | 95 - .../com/baidu/hugegraph/auth/ResourceType.java | 140 - .../com/baidu/hugegraph/auth/RolePermission.java | 234 - .../com/baidu/hugegraph/auth/SchemaDefine.java | 310 - .../baidu/hugegraph/auth/StandardAuthManager.java | 729 -- .../com/baidu/hugegraph/auth/TokenGenerator.java | 70 - .../com/baidu/hugegraph/auth/UserWithRole.java | 51 - .../baidu/hugegraph/backend/BackendException.java | 54 - .../com/baidu/hugegraph/backend/LocalCounter.java | 79 - .../com/baidu/hugegraph/backend/Transaction.java | 33 - .../hugegraph/backend/cache/AbstractCache.java | 300 - .../com/baidu/hugegraph/backend/cache/Cache.java | 71 - .../hugegraph/backend/cache/CacheManager.java | 156 - .../hugegraph/backend/cache/CacheNotifier.java | 38 - .../backend/cache/CachedBackendStore.java | 254 - .../backend/cache/CachedGraphTransaction.java | 428 - .../backend/cache/CachedSchemaTransaction.java | 446 - .../baidu/hugegraph/backend/cache/LevelCache.java | 122 - .../hugegraph/backend/cache/OffheapCache.java | 410 - .../baidu/hugegraph/backend/cache/RamCache.java | 517 -- .../com/baidu/hugegraph/backend/id/EdgeId.java | 306 - .../java/com/baidu/hugegraph/backend/id/Id.java | 88 - .../baidu/hugegraph/backend/id/IdGenerator.java | 446 - .../com/baidu/hugegraph/backend/id/IdUtil.java | 150 - .../hugegraph/backend/id/SnowflakeIdGenerator.java | 178 - .../hugegraph/backend/id/SplicingIdGenerator.java | 134 - .../com/baidu/hugegraph/backend/page/IdHolder.java | 270 - .../baidu/hugegraph/backend/page/IdHolderList.java | 65 - .../hugegraph/backend/page/PageEntryIterator.java | 131 - .../com/baidu/hugegraph/backend/page/PageIds.java | 58 - .../com/baidu/hugegraph/backend/page/PageInfo.java | 119 - .../baidu/hugegraph/backend/page/PageState.java | 113 - .../baidu/hugegraph/backend/page/QueryList.java | 368 - .../backend/page/SortByCountIdHolderList.java | 105 - .../baidu/hugegraph/backend/query/Aggregate.java | 109 - .../backend/query/BatchConditionQuery.java | 85 - .../baidu/hugegraph/backend/query/Condition.java | 814 -- .../hugegraph/backend/query/ConditionQuery.java | 876 -- .../backend/query/ConditionQueryFlatten.java | 517 -- .../hugegraph/backend/query/IdPrefixQuery.java | 109 - .../com/baidu/hugegraph/backend/query/IdQuery.java | 192 - .../hugegraph/backend/query/IdRangeQuery.java | 113 - .../com/baidu/hugegraph/backend/query/Query.java | 583 -- .../hugegraph/backend/query/QueryResults.java | 330 - .../backend/serializer/AbstractSerializer.java | 94 - .../backend/serializer/BinaryBackendEntry.java | 278 - .../backend/serializer/BinaryEntryIterator.java | 144 - .../serializer/BinaryScatterSerializer.java | 94 - .../backend/serializer/BinarySerializer.java | 1316 --- .../hugegraph/backend/serializer/BytesBuffer.java | 933 -- .../backend/serializer/GraphSerializer.java | 57 - .../backend/serializer/MergeIterator.java | 103 - .../backend/serializer/SchemaSerializer.java | 46 - .../backend/serializer/SerializerFactory.java | 86 - .../backend/serializer/TableBackendEntry.java | 298 - .../backend/serializer/TableSerializer.java | 713 -- .../backend/serializer/TextBackendEntry.java | 379 - .../backend/serializer/TextSerializer.java | 912 -- .../backend/store/AbstractBackendStore.java | 87 - .../store/AbstractBackendStoreProvider.java | 245 - .../hugegraph/backend/store/BackendAction.java | 50 - .../hugegraph/backend/store/BackendEntry.java | 226 - .../backend/store/BackendEntryIterator.java | 221 - .../hugegraph/backend/store/BackendFeatures.java | 77 - .../hugegraph/backend/store/BackendMetrics.java | 49 - .../hugegraph/backend/store/BackendMutation.java | 346 - .../backend/store/BackendProviderFactory.java | 111 - .../hugegraph/backend/store/BackendSession.java | 124 - .../backend/store/BackendSessionPool.java | 171 - .../hugegraph/backend/store/BackendStore.java | 182 - .../hugegraph/backend/store/BackendStoreInfo.java | 57 - .../backend/store/BackendStoreProvider.java | 78 - .../hugegraph/backend/store/BackendTable.java | 382 - .../hugegraph/backend/store/MetaDispatcher.java | 47 - .../baidu/hugegraph/backend/store/MetaHandler.java | 25 - .../com/baidu/hugegraph/backend/store/Shard.java | 71 - .../hugegraph/backend/store/SystemSchemaStore.java | 77 - .../baidu/hugegraph/backend/store/TableDefine.java | 89 - .../backend/store/memory/InMemoryDBStore.java | 499 -- .../store/memory/InMemoryDBStoreProvider.java | 108 - .../backend/store/memory/InMemoryDBTable.java | 359 - .../backend/store/memory/InMemoryDBTables.java | 570 -- .../backend/store/memory/InMemoryMetrics.java | 33 - .../backend/store/raft/RaftAddPeerJob.java | 50 - .../backend/store/raft/RaftBackendStore.java | 296 - .../store/raft/RaftBackendStoreProvider.java | 278 - .../hugegraph/backend/store/raft/RaftClosure.java | 95 - .../hugegraph/backend/store/raft/RaftContext.java | 456 - .../backend/store/raft/RaftException.java | 55 - .../backend/store/raft/RaftGroupManager.java | 39 - .../backend/store/raft/RaftGroupManagerImpl.java | 156 - .../hugegraph/backend/store/raft/RaftNode.java | 367 - .../backend/store/raft/RaftRemovePeerJob.java | 50 - .../hugegraph/backend/store/raft/RaftResult.java | 65 - .../backend/store/raft/RaftStoreClosure.java | 36 - .../hugegraph/backend/store/raft/StoreCommand.java | 92 - .../backend/store/raft/StoreSerializer.java | 150 - .../backend/store/raft/StoreSnapshotFile.java | 246 - .../backend/store/raft/StoreStateMachine.java | 251 - .../backend/store/raft/rpc/ListPeersProcessor.java | 76 - .../backend/store/raft/rpc/RpcForwarder.java | 162 - .../backend/store/raft/rpc/SetLeaderProcessor.java | 70 - .../store/raft/rpc/StoreCommandProcessor.java | 85 - .../hugegraph/backend/store/ram/IntIntMap.java | 78 - .../hugegraph/backend/store/ram/IntLongMap.java | 96 - .../hugegraph/backend/store/ram/IntObjectMap.java | 90 - .../baidu/hugegraph/backend/store/ram/RamMap.java | 35 - .../hugegraph/backend/store/ram/RamTable.java | 593 -- .../hugegraph/backend/tx/AbstractTransaction.java | 432 - .../backend/tx/GraphIndexTransaction.java | 1950 ---- .../hugegraph/backend/tx/GraphTransaction.java | 2091 ----- .../hugegraph/backend/tx/IndexableTransaction.java | 88 - .../backend/tx/SchemaIndexTransaction.java | 122 - .../hugegraph/backend/tx/SchemaTransaction.java | 686 -- .../com/baidu/hugegraph/config/AuthOptions.java | 131 - .../com/baidu/hugegraph/config/CoreOptions.java | 631 -- .../java/com/baidu/hugegraph/election/Config.java | 35 - .../election/RoleElectionStateMachine.java | 27 - .../election/RoleElectionStateMachineImpl.java | 312 - .../com/baidu/hugegraph/election/RoleTypeData.java | 91 - .../hugegraph/election/RoleTypeDataAdapter.java | 29 - .../hugegraph/election/StateMachineCallback.java | 35 - .../hugegraph/election/StateMachineContext.java | 37 - .../hugegraph/exception/ConnectionException.java | 40 - .../hugegraph/exception/ExistedException.java | 36 - .../hugegraph/exception/HugeGremlinException.java | 46 - .../hugegraph/exception/LimitExceedException.java | 35 - .../hugegraph/exception/NoIndexException.java | 35 - .../hugegraph/exception/NotAllowException.java | 35 - .../hugegraph/exception/NotFoundException.java | 39 - .../hugegraph/exception/NotSupportException.java | 36 - .../hugegraph/io/GraphSONSchemaSerializer.java | 131 - .../baidu/hugegraph/io/HugeGraphIoRegistry.java | 44 - .../com/baidu/hugegraph/io/HugeGraphSONModule.java | 601 -- .../com/baidu/hugegraph/io/HugeGryoModule.java | 201 - .../java/com/baidu/hugegraph/job/AlgorithmJob.java | 71 - .../java/com/baidu/hugegraph/job/ComputerJob.java | 76 - .../java/com/baidu/hugegraph/job/EphemeralJob.java | 34 - .../baidu/hugegraph/job/EphemeralJobBuilder.java | 86 - .../java/com/baidu/hugegraph/job/GremlinJob.java | 133 - .../src/main/java/com/baidu/hugegraph/job/Job.java | 27 - .../java/com/baidu/hugegraph/job/JobBuilder.java | 101 - .../main/java/com/baidu/hugegraph/job/SysJob.java | 45 - .../main/java/com/baidu/hugegraph/job/UserJob.java | 45 - .../hugegraph/job/algorithm/AbstractAlgorithm.java | 647 -- .../baidu/hugegraph/job/algorithm/Algorithm.java | 35 - .../hugegraph/job/algorithm/AlgorithmPool.java | 102 - .../hugegraph/job/algorithm/BfsTraverser.java | 154 - .../baidu/hugegraph/job/algorithm/Consumers.java | 206 - .../job/algorithm/CountEdgeAlgorithm.java | 80 - .../job/algorithm/CountVertexAlgorithm.java | 80 - .../job/algorithm/SubgraphStatAlgorithm.java | 223 - .../job/algorithm/cent/AbstractCentAlgorithm.java | 211 - .../cent/BetweennessCentralityAlgorithm.java | 150 - .../cent/BetweennessCentralityAlgorithmV2.java | 176 - .../cent/ClosenessCentralityAlgorithm.java | 108 - .../cent/ClosenessCentralityAlgorithmV2.java | 135 - .../algorithm/cent/DegreeCentralityAlgorithm.java | 164 - .../cent/EigenvectorCentralityAlgorithm.java | 102 - .../algorithm/cent/StressCentralityAlgorithm.java | 106 - .../cent/StressCentralityAlgorithmV2.java | 182 - .../job/algorithm/comm/AbstractCommAlgorithm.java | 80 - .../comm/ClusterCoefficientAlgorithm.java | 85 - .../job/algorithm/comm/KCoreAlgorithm.java | 294 - .../job/algorithm/comm/LouvainAlgorithm.java | 123 - .../job/algorithm/comm/LouvainTraverser.java | 922 -- .../hugegraph/job/algorithm/comm/LpaAlgorithm.java | 273 - .../job/algorithm/comm/TriangleCountAlgorithm.java | 241 - .../job/algorithm/comm/WeakConnectedComponent.java | 221 - .../job/algorithm/path/RingsDetectAlgorithm.java | 148 - .../job/algorithm/rank/PageRankAlgorithm.java | 338 - .../similarity/FusiformSimilarityAlgorithm.java | 200 - .../hugegraph/job/computer/AbstractComputer.java | 269 - .../com/baidu/hugegraph/job/computer/Computer.java | 35 - .../baidu/hugegraph/job/computer/ComputerPool.java | 55 - .../hugegraph/job/computer/LouvainComputer.java | 128 - .../baidu/hugegraph/job/computer/LpaComputer.java | 73 - .../hugegraph/job/computer/PageRankComputer.java | 70 - .../job/computer/TriangleCountComputer.java | 52 - .../computer/WeakConnectedComponentComputer.java | 52 - .../hugegraph/job/schema/EdgeLabelRemoveJob.java | 87 - .../hugegraph/job/schema/IndexLabelRebuildJob.java | 193 - .../hugegraph/job/schema/IndexLabelRemoveJob.java | 84 - .../job/schema/OlapPropertyKeyClearJob.java | 93 - .../job/schema/OlapPropertyKeyCreateJob.java | 42 - .../job/schema/OlapPropertyKeyRemoveJob.java | 52 - .../com/baidu/hugegraph/job/schema/SchemaJob.java | 126 - .../hugegraph/job/schema/VertexLabelRemoveJob.java | 106 - .../job/system/DeleteExpiredElementJob.java | 66 - .../job/system/DeleteExpiredIndexJob.java | 96 - .../hugegraph/job/system/DeleteExpiredJob.java | 90 - .../baidu/hugegraph/job/system/JobCounters.java | 119 - .../hugegraph/plugin/HugeGraphGremlinPlugin.java | 73 - .../baidu/hugegraph/plugin/HugeGraphPlugin.java | 52 - .../hugegraph/rpc/RpcServiceConfig4Client.java | 37 - .../hugegraph/rpc/RpcServiceConfig4Server.java | 32 - .../java/com/baidu/hugegraph/schema/EdgeLabel.java | 169 - .../com/baidu/hugegraph/schema/IndexLabel.java | 285 - .../com/baidu/hugegraph/schema/PropertyKey.java | 414 - .../com/baidu/hugegraph/schema/SchemaElement.java | 222 - .../com/baidu/hugegraph/schema/SchemaLabel.java | 181 - .../com/baidu/hugegraph/schema/SchemaManager.java | 145 - .../java/com/baidu/hugegraph/schema/Userdata.java | 66 - .../com/baidu/hugegraph/schema/VertexLabel.java | 137 - .../hugegraph/schema/builder/AbstractBuilder.java | 112 - .../hugegraph/schema/builder/EdgeLabelBuilder.java | 627 -- .../schema/builder/IndexLabelBuilder.java | 760 -- .../schema/builder/PropertyKeyBuilder.java | 468 - .../hugegraph/schema/builder/SchemaBuilder.java | 42 - .../schema/builder/VertexLabelBuilder.java | 605 -- .../hugegraph/security/HugeSecurityManager.java | 508 -- .../com/baidu/hugegraph/structure/GraphType.java | 26 - .../com/baidu/hugegraph/structure/HugeEdge.java | 541 -- .../hugegraph/structure/HugeEdgeProperty.java | 75 - .../com/baidu/hugegraph/structure/HugeElement.java | 546 -- .../baidu/hugegraph/structure/HugeFeatures.java | 416 - .../com/baidu/hugegraph/structure/HugeIndex.java | 299 - .../baidu/hugegraph/structure/HugeProperty.java | 115 - .../com/baidu/hugegraph/structure/HugeVertex.java | 708 -- .../hugegraph/structure/HugeVertexProperty.java | 88 - .../com/baidu/hugegraph/task/HugeServerInfo.java | 334 - .../java/com/baidu/hugegraph/task/HugeTask.java | 722 -- .../baidu/hugegraph/task/ServerInfoManager.java | 402 - .../hugegraph/task/StandardTaskScheduler.java | 862 -- .../com/baidu/hugegraph/task/TaskCallable.java | 191 - .../java/com/baidu/hugegraph/task/TaskManager.java | 360 - .../com/baidu/hugegraph/task/TaskScheduler.java | 67 - .../java/com/baidu/hugegraph/task/TaskStatus.java | 72 - .../algorithm/CollectionPathsTraverser.java | 279 - .../traversal/algorithm/CountTraverser.java | 139 - .../algorithm/CustomizePathsTraverser.java | 239 - .../algorithm/CustomizedCrosspointsTraverser.java | 222 - .../algorithm/FusiformSimilarityTraverser.java | 322 - .../traversal/algorithm/HugeTraverser.java | 744 -- .../algorithm/JaccardSimilarTraverser.java | 212 - .../traversal/algorithm/KneighborTraverser.java | 106 - .../traversal/algorithm/KoutTraverser.java | 149 - .../algorithm/MultiNodeShortestPathTraverser.java | 127 - .../traversal/algorithm/NeighborRankTraverser.java | 307 - .../traversal/algorithm/OltpTraverser.java | 180 - .../traversal/algorithm/PathTraverser.java | 226 - .../traversal/algorithm/PathsTraverser.java | 181 - .../traversal/algorithm/PersonalRankTraverser.java | 172 - .../traversal/algorithm/PredictionTraverser.java | 83 - .../traversal/algorithm/SameNeighborTraverser.java | 62 - .../traversal/algorithm/ShortestPathTraverser.java | 252 - .../SingleSourceShortestPathTraverser.java | 295 - .../traversal/algorithm/SubGraphTraverser.java | 304 - .../algorithm/TemplatePathsTraverser.java | 281 - .../algorithm/records/AbstractRecords.java | 83 - .../records/DoubleWayMultiPathsRecords.java | 207 - .../algorithm/records/KneighborRecords.java | 75 - .../traversal/algorithm/records/KoutRecords.java | 66 - .../traversal/algorithm/records/PathsRecords.java | 60 - .../traversal/algorithm/records/Records.java | 41 - .../algorithm/records/ShortestPathRecords.java | 117 - .../records/SingleWayMultiPathsRecords.java | 187 - .../algorithm/records/record/Int2ArrayRecord.java | 67 - .../algorithm/records/record/Int2IntRecord.java | 76 - .../algorithm/records/record/Int2SetRecord.java | 75 - .../traversal/algorithm/records/record/Record.java | 37 - .../algorithm/records/record/RecordFactory.java | 50 - .../algorithm/records/record/RecordType.java | 69 - .../algorithm/records/record/SyncRecord.java | 87 - .../traversal/algorithm/steps/EdgeStep.java | 147 - .../traversal/algorithm/steps/RepeatEdgeStep.java | 108 - .../algorithm/steps/WeightedEdgeStep.java | 104 - .../strategy/ConcurrentTraverseStrategy.java | 73 - .../algorithm/strategy/SingleTraverseStrategy.java | 75 - .../algorithm/strategy/TraverseStrategy.java | 51 - .../hugegraph/traversal/optimize/ConditionP.java | 57 - .../traversal/optimize/HugeCountStep.java | 79 - .../traversal/optimize/HugeCountStepStrategy.java | 126 - .../traversal/optimize/HugeGraphStep.java | 222 - .../traversal/optimize/HugeGraphStepStrategy.java | 79 - .../traversal/optimize/HugeScriptTraversal.java | 122 - .../traversal/optimize/HugeVertexStep.java | 255 - .../traversal/optimize/HugeVertexStepByBatch.java | 140 - .../traversal/optimize/HugeVertexStepStrategy.java | 135 - .../hugegraph/traversal/optimize/QueryHolder.java | 73 - .../baidu/hugegraph/traversal/optimize/Text.java | 34 - .../traversal/optimize/TraversalUtil.java | 972 -- .../java/com/baidu/hugegraph/type/HugeType.java | 197 - .../java/com/baidu/hugegraph/type/Idfiable.java | 27 - .../java/com/baidu/hugegraph/type/Indexable.java | 29 - .../java/com/baidu/hugegraph/type/Nameable.java | 30 - .../com/baidu/hugegraph/type/Propertiable.java | 29 - .../java/com/baidu/hugegraph/type/Typeable.java | 26 - .../com/baidu/hugegraph/type/define/Action.java | 76 - .../baidu/hugegraph/type/define/AggregateType.java | 93 - .../baidu/hugegraph/type/define/Cardinality.java | 85 - .../hugegraph/type/define/CollectionType.java | 67 - .../com/baidu/hugegraph/type/define/DataType.java | 220 - .../baidu/hugegraph/type/define/Directions.java | 117 - .../com/baidu/hugegraph/type/define/Frequency.java | 51 - .../com/baidu/hugegraph/type/define/GraphMode.java | 74 - .../baidu/hugegraph/type/define/GraphReadMode.java | 50 - .../com/baidu/hugegraph/type/define/HugeKeys.java | 105 - .../baidu/hugegraph/type/define/IdStrategy.java | 71 - .../com/baidu/hugegraph/type/define/IndexType.java | 122 - .../com/baidu/hugegraph/type/define/NodeRole.java | 63 - .../baidu/hugegraph/type/define/SchemaStatus.java | 65 - .../baidu/hugegraph/type/define/SerialEnum.java | 69 - .../com/baidu/hugegraph/type/define/WriteType.java | 67 - .../main/java/com/baidu/hugegraph/util/Blob.java | 70 - .../com/baidu/hugegraph/util/CompressUtil.java | 247 - .../java/com/baidu/hugegraph/util/ConfigUtil.java | 152 - .../java/com/baidu/hugegraph/util/Consumers.java | 319 - .../java/com/baidu/hugegraph/util/CopyUtil.java | 88 - .../main/java/com/baidu/hugegraph/util/Events.java | 35 - .../util/FixedTimerWindowRateLimiter.java | 62 - .../util/FixedWatchWindowRateLimiter.java | 62 - .../java/com/baidu/hugegraph/util/GZipUtil.java | 76 - .../java/com/baidu/hugegraph/util/JsonUtil.java | 159 - .../java/com/baidu/hugegraph/util/KryoUtil.java | 99 - .../java/com/baidu/hugegraph/util/LZ4Util.java | 95 - .../java/com/baidu/hugegraph/util/LockUtil.java | 353 - .../com/baidu/hugegraph/util/ParameterUtil.java | 78 - .../java/com/baidu/hugegraph/util/RateLimiter.java | 45 - .../java/com/baidu/hugegraph/util/Reflection.java | 116 - .../com/baidu/hugegraph/util/StringEncoding.java | 208 - .../util/collection/CollectionFactory.java | 283 - .../com/baidu/hugegraph/util/collection/IdSet.java | 120 - .../hugegraph/util/collection/Int2IntsMap.java | 218 - .../hugegraph/util/collection/IntIterator.java | 213 - .../baidu/hugegraph/util/collection/IntMap.java | 602 -- .../baidu/hugegraph/util/collection/IntSet.java | 593 -- .../util/collection/ObjectIntMapping.java | 29 - .../util/collection/ObjectIntMappingFactory.java | 138 - .../baidu/hugegraph/variables/HugeVariables.java | 393 - .../com/baidu/hugegraph/version/CoreVersion.java | 47 - .../java/org/apache/hugegraph/HugeException.java | 64 + .../java/org/apache/hugegraph/HugeFactory.java | 171 + .../main/java/org/apache/hugegraph/HugeGraph.java | 325 + .../java/org/apache/hugegraph/HugeGraphParams.java | 95 + .../org/apache/hugegraph/StandardHugeGraph.java | 1617 ++++ .../org/apache/hugegraph/analyzer/Analyzer.java | 27 + .../apache/hugegraph/analyzer/AnalyzerFactory.java | 100 + .../apache/hugegraph/analyzer/AnsjAnalyzer.java | 87 + .../apache/hugegraph/analyzer/HanLPAnalyzer.java | 106 + .../org/apache/hugegraph/analyzer/IKAnalyzer.java | 71 + .../apache/hugegraph/analyzer/JcsegAnalyzer.java | 82 + .../apache/hugegraph/analyzer/JiebaAnalyzer.java | 62 + .../apache/hugegraph/analyzer/MMSeg4JAnalyzer.java | 91 + .../apache/hugegraph/analyzer/SmartCNAnalyzer.java | 62 + .../org/apache/hugegraph/auth/AuthConstant.java | 29 + .../org/apache/hugegraph/auth/AuthManager.java | 131 + .../org/apache/hugegraph/auth/EntityManager.java | 200 + .../java/org/apache/hugegraph/auth/HugeAccess.java | 234 + .../java/org/apache/hugegraph/auth/HugeBelong.java | 201 + .../java/org/apache/hugegraph/auth/HugeGroup.java | 200 + .../org/apache/hugegraph/auth/HugePermission.java | 67 + .../org/apache/hugegraph/auth/HugeProject.java | 313 + .../org/apache/hugegraph/auth/HugeResource.java | 356 + .../java/org/apache/hugegraph/auth/HugeTarget.java | 263 + .../java/org/apache/hugegraph/auth/HugeUser.java | 286 + .../apache/hugegraph/auth/RelationshipManager.java | 243 + .../org/apache/hugegraph/auth/ResourceObject.java | 95 + .../org/apache/hugegraph/auth/ResourceType.java | 140 + .../org/apache/hugegraph/auth/RolePermission.java | 234 + .../org/apache/hugegraph/auth/SchemaDefine.java | 311 + .../apache/hugegraph/auth/StandardAuthManager.java | 729 ++ .../org/apache/hugegraph/auth/TokenGenerator.java | 70 + .../org/apache/hugegraph/auth/UserWithRole.java | 51 + .../apache/hugegraph/backend/BackendException.java | 54 + .../org/apache/hugegraph/backend/LocalCounter.java | 79 + .../org/apache/hugegraph/backend/Transaction.java | 33 + .../hugegraph/backend/cache/AbstractCache.java | 300 + .../org/apache/hugegraph/backend/cache/Cache.java | 71 + .../hugegraph/backend/cache/CacheManager.java | 156 + .../hugegraph/backend/cache/CacheNotifier.java | 38 + .../backend/cache/CachedBackendStore.java | 254 + .../backend/cache/CachedGraphTransaction.java | 428 + .../backend/cache/CachedSchemaTransaction.java | 446 + .../apache/hugegraph/backend/cache/LevelCache.java | 122 + .../hugegraph/backend/cache/OffheapCache.java | 410 + .../apache/hugegraph/backend/cache/RamCache.java | 517 ++ .../org/apache/hugegraph/backend/id/EdgeId.java | 306 + .../java/org/apache/hugegraph/backend/id/Id.java | 88 + .../apache/hugegraph/backend/id/IdGenerator.java | 446 + .../org/apache/hugegraph/backend/id/IdUtil.java | 150 + .../hugegraph/backend/id/SnowflakeIdGenerator.java | 178 + .../hugegraph/backend/id/SplicingIdGenerator.java | 134 + .../apache/hugegraph/backend/page/IdHolder.java | 270 + .../hugegraph/backend/page/IdHolderList.java | 65 + .../hugegraph/backend/page/PageEntryIterator.java | 131 + .../org/apache/hugegraph/backend/page/PageIds.java | 58 + .../apache/hugegraph/backend/page/PageInfo.java | 119 + .../apache/hugegraph/backend/page/PageState.java | 113 + .../apache/hugegraph/backend/page/QueryList.java | 368 + .../backend/page/SortByCountIdHolderList.java | 105 + .../apache/hugegraph/backend/query/Aggregate.java | 109 + .../backend/query/BatchConditionQuery.java | 85 + .../apache/hugegraph/backend/query/Condition.java | 814 ++ .../hugegraph/backend/query/ConditionQuery.java | 875 ++ .../backend/query/ConditionQueryFlatten.java | 517 ++ .../hugegraph/backend/query/IdPrefixQuery.java | 109 + .../apache/hugegraph/backend/query/IdQuery.java | 192 + .../hugegraph/backend/query/IdRangeQuery.java | 113 + .../org/apache/hugegraph/backend/query/Query.java | 583 ++ .../hugegraph/backend/query/QueryResults.java | 330 + .../backend/serializer/AbstractSerializer.java | 94 + .../backend/serializer/BinaryBackendEntry.java | 278 + .../backend/serializer/BinaryEntryIterator.java | 144 + .../serializer/BinaryScatterSerializer.java | 94 + .../backend/serializer/BinarySerializer.java | 1314 +++ .../hugegraph/backend/serializer/BytesBuffer.java | 932 ++ .../backend/serializer/GraphSerializer.java | 57 + .../backend/serializer/MergeIterator.java | 103 + .../backend/serializer/SchemaSerializer.java | 46 + .../backend/serializer/SerializerFactory.java | 86 + .../backend/serializer/TableBackendEntry.java | 298 + .../backend/serializer/TableSerializer.java | 713 ++ .../backend/serializer/TextBackendEntry.java | 379 + .../backend/serializer/TextSerializer.java | 911 ++ .../backend/store/AbstractBackendStore.java | 87 + .../store/AbstractBackendStoreProvider.java | 245 + .../hugegraph/backend/store/BackendAction.java | 50 + .../hugegraph/backend/store/BackendEntry.java | 226 + .../backend/store/BackendEntryIterator.java | 221 + .../hugegraph/backend/store/BackendFeatures.java | 77 + .../hugegraph/backend/store/BackendMetrics.java | 49 + .../hugegraph/backend/store/BackendMutation.java | 346 + .../backend/store/BackendProviderFactory.java | 111 + .../hugegraph/backend/store/BackendSession.java | 124 + .../backend/store/BackendSessionPool.java | 171 + .../hugegraph/backend/store/BackendStore.java | 182 + .../hugegraph/backend/store/BackendStoreInfo.java | 57 + .../backend/store/BackendStoreProvider.java | 78 + .../hugegraph/backend/store/BackendTable.java | 382 + .../hugegraph/backend/store/MetaDispatcher.java | 47 + .../hugegraph/backend/store/MetaHandler.java | 25 + .../org/apache/hugegraph/backend/store/Shard.java | 71 + .../hugegraph/backend/store/SystemSchemaStore.java | 77 + .../hugegraph/backend/store/TableDefine.java | 89 + .../backend/store/memory/InMemoryDBStore.java | 500 ++ .../store/memory/InMemoryDBStoreProvider.java | 108 + .../backend/store/memory/InMemoryDBTable.java | 359 + .../backend/store/memory/InMemoryDBTables.java | 570 ++ .../backend/store/memory/InMemoryMetrics.java | 33 + .../backend/store/raft/RaftAddPeerJob.java | 50 + .../backend/store/raft/RaftBackendStore.java | 296 + .../store/raft/RaftBackendStoreProvider.java | 278 + .../hugegraph/backend/store/raft/RaftClosure.java | 95 + .../hugegraph/backend/store/raft/RaftContext.java | 456 + .../backend/store/raft/RaftException.java | 55 + .../backend/store/raft/RaftGroupManager.java | 39 + .../backend/store/raft/RaftGroupManagerImpl.java | 156 + .../hugegraph/backend/store/raft/RaftNode.java | 367 + .../backend/store/raft/RaftRemovePeerJob.java | 50 + .../hugegraph/backend/store/raft/RaftResult.java | 65 + .../backend/store/raft/RaftStoreClosure.java | 36 + .../hugegraph/backend/store/raft/StoreCommand.java | 92 + .../backend/store/raft/StoreSerializer.java | 150 + .../backend/store/raft/StoreSnapshotFile.java | 246 + .../backend/store/raft/StoreStateMachine.java | 251 + .../backend/store/raft/rpc/ListPeersProcessor.java | 76 + .../backend/store/raft/rpc/RpcForwarder.java | 162 + .../backend/store/raft/rpc/SetLeaderProcessor.java | 70 + .../store/raft/rpc/StoreCommandProcessor.java | 85 + .../hugegraph/backend/store/ram/IntIntMap.java | 78 + .../hugegraph/backend/store/ram/IntLongMap.java | 96 + .../hugegraph/backend/store/ram/IntObjectMap.java | 90 + .../apache/hugegraph/backend/store/ram/RamMap.java | 35 + .../hugegraph/backend/store/ram/RamTable.java | 593 ++ .../hugegraph/backend/tx/AbstractTransaction.java | 432 + .../backend/tx/GraphIndexTransaction.java | 1951 ++++ .../hugegraph/backend/tx/GraphTransaction.java | 2091 +++++ .../hugegraph/backend/tx/IndexableTransaction.java | 88 + .../backend/tx/SchemaIndexTransaction.java | 122 + .../hugegraph/backend/tx/SchemaTransaction.java | 686 ++ .../org/apache/hugegraph/config/AuthOptions.java | 131 + .../org/apache/hugegraph/config/CoreOptions.java | 632 ++ .../java/org/apache/hugegraph/election/Config.java | 35 + .../election/RoleElectionStateMachine.java | 27 + .../election/RoleElectionStateMachineImpl.java | 312 + .../apache/hugegraph/election/RoleTypeData.java | 91 + .../hugegraph/election/RoleTypeDataAdapter.java | 29 + .../hugegraph/election/StateMachineCallback.java | 35 + .../hugegraph/election/StateMachineContext.java | 37 + .../hugegraph/exception/ConnectionException.java | 40 + .../hugegraph/exception/ExistedException.java | 36 + .../hugegraph/exception/HugeGremlinException.java | 46 + .../hugegraph/exception/LimitExceedException.java | 35 + .../hugegraph/exception/NoIndexException.java | 35 + .../hugegraph/exception/NotAllowException.java | 35 + .../hugegraph/exception/NotFoundException.java | 39 + .../hugegraph/exception/NotSupportException.java | 36 + .../hugegraph/io/GraphSONSchemaSerializer.java | 131 + .../apache/hugegraph/io/HugeGraphIoRegistry.java | 44 + .../apache/hugegraph/io/HugeGraphSONModule.java | 601 ++ .../org/apache/hugegraph/io/HugeGryoModule.java | 200 + .../org/apache/hugegraph/job/AlgorithmJob.java | 71 + .../java/org/apache/hugegraph/job/ComputerJob.java | 76 + .../org/apache/hugegraph/job/EphemeralJob.java | 34 + .../apache/hugegraph/job/EphemeralJobBuilder.java | 86 + .../java/org/apache/hugegraph/job/GremlinJob.java | 133 + .../main/java/org/apache/hugegraph/job/Job.java | 27 + .../java/org/apache/hugegraph/job/JobBuilder.java | 101 + .../main/java/org/apache/hugegraph/job/SysJob.java | 45 + .../java/org/apache/hugegraph/job/UserJob.java | 45 + .../hugegraph/job/algorithm/AbstractAlgorithm.java | 647 ++ .../apache/hugegraph/job/algorithm/Algorithm.java | 35 + .../hugegraph/job/algorithm/AlgorithmPool.java | 102 + .../hugegraph/job/algorithm/BfsTraverser.java | 154 + .../apache/hugegraph/job/algorithm/Consumers.java | 206 + .../job/algorithm/CountEdgeAlgorithm.java | 80 + .../job/algorithm/CountVertexAlgorithm.java | 80 + .../job/algorithm/SubgraphStatAlgorithm.java | 223 + .../job/algorithm/cent/AbstractCentAlgorithm.java | 211 + .../cent/BetweennessCentralityAlgorithm.java | 150 + .../cent/BetweennessCentralityAlgorithmV2.java | 176 + .../cent/ClosenessCentralityAlgorithm.java | 108 + .../cent/ClosenessCentralityAlgorithmV2.java | 135 + .../algorithm/cent/DegreeCentralityAlgorithm.java | 164 + .../cent/EigenvectorCentralityAlgorithm.java | 102 + .../algorithm/cent/StressCentralityAlgorithm.java | 106 + .../cent/StressCentralityAlgorithmV2.java | 182 + .../job/algorithm/comm/AbstractCommAlgorithm.java | 80 + .../comm/ClusterCoefficientAlgorithm.java | 85 + .../job/algorithm/comm/KCoreAlgorithm.java | 294 + .../job/algorithm/comm/LouvainAlgorithm.java | 123 + .../job/algorithm/comm/LouvainTraverser.java | 922 ++ .../hugegraph/job/algorithm/comm/LpaAlgorithm.java | 273 + .../job/algorithm/comm/TriangleCountAlgorithm.java | 241 + .../job/algorithm/comm/WeakConnectedComponent.java | 221 + .../job/algorithm/path/RingsDetectAlgorithm.java | 148 + .../job/algorithm/rank/PageRankAlgorithm.java | 338 + .../similarity/FusiformSimilarityAlgorithm.java | 200 + .../hugegraph/job/computer/AbstractComputer.java | 270 + .../apache/hugegraph/job/computer/Computer.java | 35 + .../hugegraph/job/computer/ComputerPool.java | 55 + .../hugegraph/job/computer/LouvainComputer.java | 128 + .../apache/hugegraph/job/computer/LpaComputer.java | 73 + .../hugegraph/job/computer/PageRankComputer.java | 70 + .../job/computer/TriangleCountComputer.java | 52 + .../computer/WeakConnectedComponentComputer.java | 52 + .../hugegraph/job/schema/EdgeLabelRemoveJob.java | 87 + .../hugegraph/job/schema/IndexLabelRebuildJob.java | 193 + .../hugegraph/job/schema/IndexLabelRemoveJob.java | 84 + .../job/schema/OlapPropertyKeyClearJob.java | 93 + .../job/schema/OlapPropertyKeyCreateJob.java | 42 + .../job/schema/OlapPropertyKeyRemoveJob.java | 52 + .../org/apache/hugegraph/job/schema/SchemaJob.java | 126 + .../hugegraph/job/schema/VertexLabelRemoveJob.java | 106 + .../job/system/DeleteExpiredElementJob.java | 66 + .../job/system/DeleteExpiredIndexJob.java | 96 + .../hugegraph/job/system/DeleteExpiredJob.java | 90 + .../apache/hugegraph/job/system/JobCounters.java | 119 + .../hugegraph/plugin/HugeGraphGremlinPlugin.java | 73 + .../apache/hugegraph/plugin/HugeGraphPlugin.java | 52 + .../hugegraph/rpc/RpcServiceConfig4Client.java | 37 + .../hugegraph/rpc/RpcServiceConfig4Server.java | 32 + .../org/apache/hugegraph/schema/EdgeLabel.java | 169 + .../org/apache/hugegraph/schema/IndexLabel.java | 285 + .../org/apache/hugegraph/schema/PropertyKey.java | 414 + .../org/apache/hugegraph/schema/SchemaElement.java | 222 + .../org/apache/hugegraph/schema/SchemaLabel.java | 181 + .../org/apache/hugegraph/schema/SchemaManager.java | 145 + .../java/org/apache/hugegraph/schema/Userdata.java | 66 + .../org/apache/hugegraph/schema/VertexLabel.java | 137 + .../hugegraph/schema/builder/AbstractBuilder.java | 112 + .../hugegraph/schema/builder/EdgeLabelBuilder.java | 627 ++ .../schema/builder/IndexLabelBuilder.java | 760 ++ .../schema/builder/PropertyKeyBuilder.java | 468 + .../hugegraph/schema/builder/SchemaBuilder.java | 42 + .../schema/builder/VertexLabelBuilder.java | 605 ++ .../hugegraph/security/HugeSecurityManager.java | 508 ++ .../org/apache/hugegraph/structure/GraphType.java | 26 + .../org/apache/hugegraph/structure/HugeEdge.java | 541 ++ .../hugegraph/structure/HugeEdgeProperty.java | 75 + .../apache/hugegraph/structure/HugeElement.java | 546 ++ .../apache/hugegraph/structure/HugeFeatures.java | 415 + .../org/apache/hugegraph/structure/HugeIndex.java | 299 + .../apache/hugegraph/structure/HugeProperty.java | 115 + .../org/apache/hugegraph/structure/HugeVertex.java | 708 ++ .../hugegraph/structure/HugeVertexProperty.java | 88 + .../org/apache/hugegraph/task/HugeServerInfo.java | 334 + .../java/org/apache/hugegraph/task/HugeTask.java | 720 ++ .../apache/hugegraph/task/ServerInfoManager.java | 403 + .../hugegraph/task/StandardTaskScheduler.java | 862 ++ .../org/apache/hugegraph/task/TaskCallable.java | 191 + .../org/apache/hugegraph/task/TaskManager.java | 358 + .../org/apache/hugegraph/task/TaskScheduler.java | 67 + .../java/org/apache/hugegraph/task/TaskStatus.java | 72 + .../algorithm/CollectionPathsTraverser.java | 279 + .../traversal/algorithm/CountTraverser.java | 139 + .../algorithm/CustomizePathsTraverser.java | 239 + .../algorithm/CustomizedCrosspointsTraverser.java | 222 + .../algorithm/FusiformSimilarityTraverser.java | 322 + .../traversal/algorithm/HugeTraverser.java | 744 ++ .../algorithm/JaccardSimilarTraverser.java | 212 + .../traversal/algorithm/KneighborTraverser.java | 106 + .../traversal/algorithm/KoutTraverser.java | 149 + .../algorithm/MultiNodeShortestPathTraverser.java | 127 + .../traversal/algorithm/NeighborRankTraverser.java | 307 + .../traversal/algorithm/OltpTraverser.java | 180 + .../traversal/algorithm/PathTraverser.java | 226 + .../traversal/algorithm/PathsTraverser.java | 181 + .../traversal/algorithm/PersonalRankTraverser.java | 172 + .../traversal/algorithm/PredictionTraverser.java | 83 + .../traversal/algorithm/SameNeighborTraverser.java | 62 + .../traversal/algorithm/ShortestPathTraverser.java | 252 + .../SingleSourceShortestPathTraverser.java | 295 + .../traversal/algorithm/SubGraphTraverser.java | 304 + .../algorithm/TemplatePathsTraverser.java | 281 + .../algorithm/records/AbstractRecords.java | 83 + .../records/DoubleWayMultiPathsRecords.java | 207 + .../algorithm/records/KneighborRecords.java | 74 + .../traversal/algorithm/records/KoutRecords.java | 65 + .../traversal/algorithm/records/PathsRecords.java | 60 + .../traversal/algorithm/records/Records.java | 41 + .../algorithm/records/ShortestPathRecords.java | 117 + .../records/SingleWayMultiPathsRecords.java | 186 + .../algorithm/records/record/Int2ArrayRecord.java | 67 + .../algorithm/records/record/Int2IntRecord.java | 76 + .../algorithm/records/record/Int2SetRecord.java | 74 + .../traversal/algorithm/records/record/Record.java | 37 + .../algorithm/records/record/RecordFactory.java | 50 + .../algorithm/records/record/RecordType.java | 69 + .../algorithm/records/record/SyncRecord.java | 87 + .../traversal/algorithm/steps/EdgeStep.java | 147 + .../traversal/algorithm/steps/RepeatEdgeStep.java | 108 + .../algorithm/steps/WeightedEdgeStep.java | 104 + .../strategy/ConcurrentTraverseStrategy.java | 73 + .../algorithm/strategy/SingleTraverseStrategy.java | 75 + .../algorithm/strategy/TraverseStrategy.java | 51 + .../hugegraph/traversal/optimize/ConditionP.java | 56 + .../traversal/optimize/HugeCountStep.java | 79 + .../traversal/optimize/HugeCountStepStrategy.java | 125 + .../traversal/optimize/HugeGraphStep.java | 222 + .../traversal/optimize/HugeGraphStepStrategy.java | 79 + .../traversal/optimize/HugeScriptTraversal.java | 121 + .../traversal/optimize/HugeVertexStep.java | 255 + .../traversal/optimize/HugeVertexStepByBatch.java | 140 + .../traversal/optimize/HugeVertexStepStrategy.java | 134 + .../hugegraph/traversal/optimize/QueryHolder.java | 73 + .../apache/hugegraph/traversal/optimize/Text.java | 34 + .../traversal/optimize/TraversalUtil.java | 970 ++ .../java/org/apache/hugegraph/type/HugeType.java | 197 + .../java/org/apache/hugegraph/type/Idfiable.java | 27 + .../java/org/apache/hugegraph/type/Indexable.java | 29 + .../java/org/apache/hugegraph/type/Nameable.java | 35 + .../org/apache/hugegraph/type/Propertiable.java | 29 + .../java/org/apache/hugegraph/type/Typeable.java | 26 + .../org/apache/hugegraph/type/define/Action.java | 76 + .../hugegraph/type/define/AggregateType.java | 93 + .../apache/hugegraph/type/define/Cardinality.java | 90 + .../hugegraph/type/define/CollectionType.java | 67 + .../org/apache/hugegraph/type/define/DataType.java | 220 + .../apache/hugegraph/type/define/Directions.java | 116 + .../apache/hugegraph/type/define/Frequency.java | 51 + .../apache/hugegraph/type/define/GraphMode.java | 74 + .../hugegraph/type/define/GraphReadMode.java | 50 + .../org/apache/hugegraph/type/define/HugeKeys.java | 105 + .../apache/hugegraph/type/define/IdStrategy.java | 71 + .../apache/hugegraph/type/define/IndexType.java | 122 + .../org/apache/hugegraph/type/define/NodeRole.java | 63 + .../apache/hugegraph/type/define/SchemaStatus.java | 65 + .../apache/hugegraph/type/define/SerialEnum.java | 69 + .../apache/hugegraph/type/define/WriteType.java | 67 + .../main/java/org/apache/hugegraph/util/Blob.java | 70 + .../org/apache/hugegraph/util/CompressUtil.java | 249 + .../java/org/apache/hugegraph/util/ConfigUtil.java | 154 + .../java/org/apache/hugegraph/util/Consumers.java | 319 + .../java/org/apache/hugegraph/util/CopyUtil.java | 88 + .../java/org/apache/hugegraph/util/Events.java | 35 + .../util/FixedTimerWindowRateLimiter.java | 62 + .../util/FixedWatchWindowRateLimiter.java | 62 + .../java/org/apache/hugegraph/util/GZipUtil.java | 76 + .../java/org/apache/hugegraph/util/JsonUtil.java | 159 + .../java/org/apache/hugegraph/util/KryoUtil.java | 98 + .../java/org/apache/hugegraph/util/LZ4Util.java | 95 + .../java/org/apache/hugegraph/util/LockUtil.java | 353 + .../org/apache/hugegraph/util/ParameterUtil.java | 80 + .../org/apache/hugegraph/util/RateLimiter.java | 45 + .../java/org/apache/hugegraph/util/Reflection.java | 116 + .../org/apache/hugegraph/util/StringEncoding.java | 195 + .../util/collection/CollectionFactory.java | 283 + .../apache/hugegraph/util/collection/IdSet.java | 120 + .../hugegraph/util/collection/Int2IntsMap.java | 218 + .../hugegraph/util/collection/IntIterator.java | 213 + .../apache/hugegraph/util/collection/IntMap.java | 602 ++ .../apache/hugegraph/util/collection/IntSet.java | 593 ++ .../util/collection/ObjectIntMapping.java | 29 + .../util/collection/ObjectIntMappingFactory.java | 138 + .../apache/hugegraph/variables/HugeVariables.java | 393 + .../org/apache/hugegraph/version/CoreVersion.java | 46 + ...g.apache.tinkerpop.gremlin.jsr223.GremlinPlugin | 2 +- .../src/main/resources/hugegraph.properties | 2 +- hugegraph-core/src/main/resources/proto/raft.proto | 4 +- .../backend/store/raft/rpc/RaftRequests.java | 5191 ----------- .../backend/store/raft/rpc/RaftRequests.java | 5015 +++++++++++ hugegraph-dist/pom.xml | 41 +- .../release-docs/licenses/LICENSE-commons-text.txt | 202 + .../licenses/LICENSE-commons-text.txt | 202 - .../scripts/dependency/known-dependencies.txt | 16 +- .../src/assembly/static/bin/checksocket.sh | 2 +- .../src/assembly/static/bin/dump-conf.sh | 2 +- .../src/assembly/static/bin/dump-store.sh | 2 +- .../src/assembly/static/bin/gremlin-console.sh | 2 +- hugegraph-dist/src/assembly/static/bin/hugegraph | 2 +- .../src/assembly/static/bin/hugegraph-server.sh | 4 +- .../src/assembly/static/bin/init-store.sh | 2 +- .../static/conf/graphs/hugegraph.properties | 4 +- .../static/conf/gremlin-driver-settings.yaml | 2 +- .../src/assembly/static/conf/gremlin-server.yaml | 66 +- hugegraph-dist/src/assembly/static/conf/log4j2.xml | 6 +- .../src/assembly/static/conf/remote-objects.yaml | 2 +- .../src/assembly/static/conf/remote.yaml | 2 +- .../assembly/static/conf/rest-server.properties | 4 +- hugegraph-dist/src/assembly/static/ext/plugins.txt | 2 +- .../src/assembly/static/scripts/example.groovy | 4 +- hugegraph-dist/src/assembly/travis/build-report.sh | 8 +- .../travis/conf-raft1/graphs/hugegraph.properties | 4 +- .../assembly/travis/conf-raft1/gremlin-server.yaml | 68 +- .../travis/conf-raft1/rest-server.properties | 2 +- .../travis/conf-raft2/graphs/hugegraph.properties | 4 +- .../assembly/travis/conf-raft2/gremlin-server.yaml | 68 +- .../travis/conf-raft2/rest-server.properties | 2 +- .../travis/conf-raft3/graphs/hugegraph.properties | 4 +- .../assembly/travis/conf-raft3/gremlin-server.yaml | 68 +- .../travis/conf-raft3/rest-server.properties | 2 +- hugegraph-dist/src/assembly/travis/run-api-test.sh | 8 +- .../java/com/baidu/hugegraph/cmd/ConfDumper.java | 74 - .../java/com/baidu/hugegraph/cmd/InitStore.java | 145 - .../java/com/baidu/hugegraph/cmd/StoreDumper.java | 102 - .../java/com/baidu/hugegraph/dist/DistOptions.java | 50 - .../com/baidu/hugegraph/dist/HugeGraphServer.java | 149 - .../baidu/hugegraph/dist/HugeGremlinServer.java | 69 - .../com/baidu/hugegraph/dist/HugeRestServer.java | 36 - .../com/baidu/hugegraph/dist/RegisterUtil.java | 222 - .../java/org/apache/hugegraph/cmd/ConfDumper.java | 74 + .../java/org/apache/hugegraph/cmd/InitStore.java | 145 + .../java/org/apache/hugegraph/cmd/StoreDumper.java | 102 + .../org/apache/hugegraph/dist/DistOptions.java | 50 + .../org/apache/hugegraph/dist/HugeGraphServer.java | 149 + .../apache/hugegraph/dist/HugeGremlinServer.java | 69 + .../org/apache/hugegraph/dist/HugeRestServer.java | 36 + .../org/apache/hugegraph/dist/RegisterUtil.java | 222 + hugegraph-dist/src/main/resources/log4j2.xml | 6 +- hugegraph-example/pom.xml | 13 +- .../java/com/baidu/hugegraph/example/Example1.java | 491 - .../java/com/baidu/hugegraph/example/Example2.java | 264 - .../java/com/baidu/hugegraph/example/Example3.java | 174 - .../com/baidu/hugegraph/example/ExampleUtil.java | 110 - .../hugegraph/example/GraphOfTheMoviesExample.java | 691 -- .../com/baidu/hugegraph/example/PerfExample1.java | 143 - .../com/baidu/hugegraph/example/PerfExample2.java | 126 - .../com/baidu/hugegraph/example/PerfExample3.java | 105 - .../com/baidu/hugegraph/example/PerfExample4.java | 89 - .../baidu/hugegraph/example/PerfExampleBase.java | 318 - .../com/baidu/hugegraph/example/TaskExample.java | 111 - .../hugegraph/example/ThreadRangePerfTest.java | 62 - .../org/apache/hugegraph/example/Example1.java | 491 + .../org/apache/hugegraph/example/Example2.java | 264 + .../org/apache/hugegraph/example/Example3.java | 174 + .../org/apache/hugegraph/example/ExampleUtil.java | 110 + .../hugegraph/example/GraphOfTheMoviesExample.java | 691 ++ .../org/apache/hugegraph/example/PerfExample1.java | 143 + .../org/apache/hugegraph/example/PerfExample2.java | 126 + .../org/apache/hugegraph/example/PerfExample3.java | 105 + .../org/apache/hugegraph/example/PerfExample4.java | 89 + .../apache/hugegraph/example/PerfExampleBase.java | 318 + .../org/apache/hugegraph/example/TaskExample.java | 111 + .../hugegraph/example/ThreadRangePerfTest.java | 62 + .../src/main/resources/hugegraph.properties | 2 +- hugegraph-example/src/main/resources/log4j2.xml | 6 +- hugegraph-hbase/pom.xml | 13 +- .../backend/store/hbase/HbaseFeatures.java | 144 - .../backend/store/hbase/HbaseMetrics.java | 203 - .../backend/store/hbase/HbaseOptions.java | 165 - .../backend/store/hbase/HbaseSerializer.java | 54 - .../backend/store/hbase/HbaseSessions.java | 964 -- .../hugegraph/backend/store/hbase/HbaseStore.java | 594 -- .../backend/store/hbase/HbaseStoreProvider.java | 77 - .../hugegraph/backend/store/hbase/HbaseTable.java | 408 - .../hugegraph/backend/store/hbase/HbaseTables.java | 368 - .../backend/store/hbase/HbaseFeatures.java | 144 + .../backend/store/hbase/HbaseMetrics.java | 203 + .../backend/store/hbase/HbaseOptions.java | 165 + .../backend/store/hbase/HbaseSerializer.java | 54 + .../backend/store/hbase/HbaseSessions.java | 964 ++ .../hugegraph/backend/store/hbase/HbaseStore.java | 593 ++ .../backend/store/hbase/HbaseStoreProvider.java | 74 + .../hugegraph/backend/store/hbase/HbaseTable.java | 404 + .../hugegraph/backend/store/hbase/HbaseTables.java | 366 + hugegraph-mysql/pom.xml | 13 +- .../backend/store/mysql/MysqlBackendEntry.java | 43 - .../backend/store/mysql/MysqlEntryIterator.java | 199 - .../backend/store/mysql/MysqlFeatures.java | 133 - .../backend/store/mysql/MysqlMetrics.java | 33 - .../backend/store/mysql/MysqlOptions.java | 119 - .../backend/store/mysql/MysqlSerializer.java | 178 - .../backend/store/mysql/MysqlSessions.java | 546 -- .../hugegraph/backend/store/mysql/MysqlStore.java | 516 -- .../backend/store/mysql/MysqlStoreProvider.java | 78 - .../hugegraph/backend/store/mysql/MysqlTable.java | 851 -- .../hugegraph/backend/store/mysql/MysqlTables.java | 667 -- .../hugegraph/backend/store/mysql/MysqlUtil.java | 131 - .../backend/store/mysql/ResultSetWrapper.java | 63 - .../backend/store/mysql/WhereBuilder.java | 289 - .../backend/store/mysql/MysqlBackendEntry.java | 43 + .../backend/store/mysql/MysqlEntryIterator.java | 199 + .../backend/store/mysql/MysqlFeatures.java | 133 + .../backend/store/mysql/MysqlMetrics.java | 33 + .../backend/store/mysql/MysqlOptions.java | 119 + .../backend/store/mysql/MysqlSerializer.java | 178 + .../backend/store/mysql/MysqlSessions.java | 546 ++ .../hugegraph/backend/store/mysql/MysqlStore.java | 516 ++ .../backend/store/mysql/MysqlStoreProvider.java | 78 + .../hugegraph/backend/store/mysql/MysqlTable.java | 849 ++ .../hugegraph/backend/store/mysql/MysqlTables.java | 666 ++ .../hugegraph/backend/store/mysql/MysqlUtil.java | 131 + .../backend/store/mysql/ResultSetWrapper.java | 63 + .../backend/store/mysql/WhereBuilder.java | 289 + hugegraph-palo/pom.xml | 18 +- .../hugegraph/backend/store/palo/PaloFeatures.java | 136 - .../hugegraph/backend/store/palo/PaloFile.java | 194 - .../backend/store/palo/PaloHttpClient.java | 78 - .../hugegraph/backend/store/palo/PaloLoadInfo.java | 192 - .../hugegraph/backend/store/palo/PaloOptions.java | 110 - .../backend/store/palo/PaloSerializer.java | 47 - .../hugegraph/backend/store/palo/PaloSessions.java | 319 - .../hugegraph/backend/store/palo/PaloStore.java | 53 - .../backend/store/palo/PaloStoreProvider.java | 177 - .../hugegraph/backend/store/palo/PaloTable.java | 116 - .../hugegraph/backend/store/palo/PaloTables.java | 474 - .../hugegraph/backend/store/palo/PaloFeatures.java | 136 + .../hugegraph/backend/store/palo/PaloFile.java | 194 + .../backend/store/palo/PaloHttpClient.java | 78 + .../hugegraph/backend/store/palo/PaloLoadInfo.java | 192 + .../hugegraph/backend/store/palo/PaloOptions.java | 110 + .../backend/store/palo/PaloSerializer.java | 47 + .../hugegraph/backend/store/palo/PaloSessions.java | 319 + .../hugegraph/backend/store/palo/PaloStore.java | 53 + .../backend/store/palo/PaloStoreProvider.java | 177 + .../hugegraph/backend/store/palo/PaloTable.java | 116 + .../hugegraph/backend/store/palo/PaloTables.java | 474 + hugegraph-postgresql/pom.xml | 18 +- .../store/postgresql/PostgresqlOptions.java | 51 - .../store/postgresql/PostgresqlSerializer.java | 61 - .../store/postgresql/PostgresqlSessions.java | 137 - .../backend/store/postgresql/PostgresqlStore.java | 37 - .../store/postgresql/PostgresqlStoreProvider.java | 224 - .../backend/store/postgresql/PostgresqlTable.java | 172 - .../backend/store/postgresql/PostgresqlTables.java | 293 - .../store/postgresql/PostgresqlOptions.java | 51 + .../store/postgresql/PostgresqlSerializer.java | 61 + .../store/postgresql/PostgresqlSessions.java | 137 + .../backend/store/postgresql/PostgresqlStore.java | 37 + .../store/postgresql/PostgresqlStoreProvider.java | 224 + .../backend/store/postgresql/PostgresqlTable.java | 172 + .../backend/store/postgresql/PostgresqlTables.java | 293 + hugegraph-rocksdb/pom.xml | 13 +- .../backend/store/rocksdb/OpenedRocksDB.java | 191 - .../backend/store/rocksdb/RocksDBFeatures.java | 148 - .../backend/store/rocksdb/RocksDBIngester.java | 109 - .../backend/store/rocksdb/RocksDBIteratorPool.java | 185 - .../backend/store/rocksdb/RocksDBMetrics.java | 239 - .../backend/store/rocksdb/RocksDBOptions.java | 701 -- .../backend/store/rocksdb/RocksDBSessions.java | 138 - .../backend/store/rocksdb/RocksDBStdSessions.java | 1359 --- .../backend/store/rocksdb/RocksDBStore.java | 1164 --- .../store/rocksdb/RocksDBStoreProvider.java | 103 - .../backend/store/rocksdb/RocksDBTable.java | 372 - .../backend/store/rocksdb/RocksDBTables.java | 480 - .../store/rocksdbsst/RocksDBSstSessions.java | 449 - .../backend/store/rocksdbsst/RocksDBSstStore.java | 116 - .../store/rocksdbsst/RocksDBSstStoreProvider.java | 38 - .../backend/store/rocksdb/OpenedRocksDB.java | 191 + .../backend/store/rocksdb/RocksDBFeatures.java | 148 + .../backend/store/rocksdb/RocksDBIngester.java | 109 + .../backend/store/rocksdb/RocksDBIteratorPool.java | 185 + .../backend/store/rocksdb/RocksDBMetrics.java | 239 + .../backend/store/rocksdb/RocksDBOptions.java | 701 ++ .../backend/store/rocksdb/RocksDBSessions.java | 138 + .../backend/store/rocksdb/RocksDBStdSessions.java | 1358 +++ .../backend/store/rocksdb/RocksDBStore.java | 1163 +++ .../store/rocksdb/RocksDBStoreProvider.java | 100 + .../backend/store/rocksdb/RocksDBTable.java | 370 + .../backend/store/rocksdb/RocksDBTables.java | 479 + .../store/rocksdbsst/RocksDBSstSessions.java | 449 + .../backend/store/rocksdbsst/RocksDBSstStore.java | 116 + .../store/rocksdbsst/RocksDBSstStoreProvider.java | 37 + hugegraph-scylladb/pom.xml | 13 +- .../backend/store/scylladb/ScyllaDBFeatures.java | 35 - .../backend/store/scylladb/ScyllaDBMetrics.java | 72 - .../store/scylladb/ScyllaDBStoreProvider.java | 176 - .../store/scylladb/ScyllaDBTablesWithMV.java | 303 - .../backend/store/scylladb/ScyllaDBFeatures.java | 35 + .../backend/store/scylladb/ScyllaDBMetrics.java | 72 + .../store/scylladb/ScyllaDBStoreProvider.java | 176 + .../store/scylladb/ScyllaDBTablesWithMV.java | 303 + hugegraph-test/pom.xml | 43 +- .../java/com/baidu/hugegraph/api/ApiTestSuite.java | 52 - .../java/com/baidu/hugegraph/api/BaseApiTest.java | 648 -- .../com/baidu/hugegraph/api/CypherApiTest.java | 86 - .../java/com/baidu/hugegraph/api/EdgeApiTest.java | 209 - .../com/baidu/hugegraph/api/EdgeLabelApiTest.java | 140 - .../com/baidu/hugegraph/api/GremlinApiTest.java | 224 - .../com/baidu/hugegraph/api/IndexLabelApiTest.java | 157 - .../java/com/baidu/hugegraph/api/LoginApiTest.java | 170 - .../com/baidu/hugegraph/api/MetricsApiTest.java | 292 - .../com/baidu/hugegraph/api/ProjectApiTest.java | 264 - .../baidu/hugegraph/api/PropertyKeyApiTest.java | 91 - .../com/baidu/hugegraph/api/SchemaApiTest.java | 39 - .../java/com/baidu/hugegraph/api/TaskApiTest.java | 167 - .../java/com/baidu/hugegraph/api/UserApiTest.java | 183 - .../com/baidu/hugegraph/api/VertexApiTest.java | 102 - .../baidu/hugegraph/api/VertexLabelApiTest.java | 127 - .../api/traversers/AdamicAdarAPITest.java | 58 - .../api/traversers/AllShortestPathsApiTest.java | 66 - .../hugegraph/api/traversers/CountApiTest.java | 62 - .../api/traversers/CrosspointsApiTest.java | 62 - .../traversers/CustomizedCrosspointsApiTest.java | 67 - .../hugegraph/api/traversers/EdgesApiTest.java | 91 - .../api/traversers/FusiformSimilarityApiTest.java | 74 - .../api/traversers/JaccardSimilarityApiTest.java | 86 - .../hugegraph/api/traversers/KneighborApiTest.java | 87 - .../hugegraph/api/traversers/KoutApiTest.java | 101 - .../traversers/MultiNodeShortestPathApiTest.java | 68 - .../api/traversers/NeighborRankApiTest.java | 59 - .../hugegraph/api/traversers/PathsApiTest.java | 87 - .../api/traversers/PersonalRankApiTest.java | 58 - .../hugegraph/api/traversers/RaysApiTest.java | 65 - .../api/traversers/ResourceAllocationAPITest.java | 58 - .../hugegraph/api/traversers/RingsApiTest.java | 59 - .../api/traversers/SameNeighborsApiTest.java | 62 - .../api/traversers/ShortestPathApiTest.java | 63 - .../SingleSourceShortestPathApiTest.java | 57 - .../api/traversers/TemplatePathsApiTest.java | 88 - .../api/traversers/TraversersApiTestSuite.java | 51 - .../traversers/WeightedShortestPathApiTest.java | 68 - .../java/com/baidu/hugegraph/core/AuthTest.java | 1578 ---- .../com/baidu/hugegraph/core/BaseCoreTest.java | 125 - .../com/baidu/hugegraph/core/CoreTestSuite.java | 97 - .../com/baidu/hugegraph/core/EdgeCoreTest.java | 7530 ---------------- .../baidu/hugegraph/core/EdgeLabelCoreTest.java | 1387 --- .../baidu/hugegraph/core/IndexLabelCoreTest.java | 1887 ---- .../com/baidu/hugegraph/core/MultiGraphsTest.java | 415 - .../com/baidu/hugegraph/core/PropertyCoreTest.java | 804 -- .../baidu/hugegraph/core/PropertyKeyCoreTest.java | 726 -- .../com/baidu/hugegraph/core/RamTableTest.java | 837 -- .../com/baidu/hugegraph/core/RestoreCoreTest.java | 728 -- .../core/RoleElectionStateMachineTest.java | 325 - .../com/baidu/hugegraph/core/SchemaCoreTest.java | 163 - .../com/baidu/hugegraph/core/TaskCoreTest.java | 714 -- .../com/baidu/hugegraph/core/VertexCoreTest.java | 9343 -------------------- .../baidu/hugegraph/core/VertexLabelCoreTest.java | 1220 --- .../com/baidu/hugegraph/testutil/FakeObjects.java | 86 - .../java/com/baidu/hugegraph/testutil/Utils.java | 114 - .../hugegraph/tinkerpop/ProcessBasicSuite.java | 301 - .../hugegraph/tinkerpop/ProcessStandardTest.java | 29 - .../tinkerpop/ProcessTestGraphProvider.java | 31 - .../hugegraph/tinkerpop/StructureBasicSuite.java | 126 - .../hugegraph/tinkerpop/StructureStandardTest.java | 29 - .../tinkerpop/StructureTestGraphProvider.java | 31 - .../com/baidu/hugegraph/tinkerpop/TestGraph.java | 951 -- .../hugegraph/tinkerpop/TestGraphFactory.java | 30 - .../hugegraph/tinkerpop/TestGraphProvider.java | 448 - .../tinkerpop/tests/HugeGraphWriteTest.java | 49 - .../com/baidu/hugegraph/unit/BaseUnitTest.java | 85 - .../java/com/baidu/hugegraph/unit/FakeObjects.java | 216 - .../com/baidu/hugegraph/unit/UnitTestSuite.java | 156 - .../hugegraph/unit/cache/CacheManagerTest.java | 315 - .../com/baidu/hugegraph/unit/cache/CacheTest.java | 774 -- .../unit/cache/CachedGraphTransactionTest.java | 224 - .../unit/cache/CachedSchemaTransactionTest.java | 203 - .../baidu/hugegraph/unit/cache/RamTableTest.java | 284 - .../hugegraph/unit/cassandra/CassandraTest.java | 197 - .../baidu/hugegraph/unit/core/AnalyzerTest.java | 206 - .../hugegraph/unit/core/BackendMutationTest.java | 358 - .../hugegraph/unit/core/BackendStoreInfoTest.java | 50 - .../unit/core/ConditionQueryFlattenTest.java | 262 - .../baidu/hugegraph/unit/core/ConditionTest.java | 647 -- .../baidu/hugegraph/unit/core/DataTypeTest.java | 88 - .../baidu/hugegraph/unit/core/DirectionsTest.java | 79 - .../baidu/hugegraph/unit/core/ExceptionTest.java | 45 - .../baidu/hugegraph/unit/core/LocksTableTest.java | 309 - .../baidu/hugegraph/unit/core/PageStateTest.java | 90 - .../com/baidu/hugegraph/unit/core/QueryTest.java | 171 - .../com/baidu/hugegraph/unit/core/RangeTest.java | 172 - .../hugegraph/unit/core/RolePermissionTest.java | 584 -- .../com/baidu/hugegraph/unit/core/RowLockTest.java | 101 - .../hugegraph/unit/core/SecurityManagerTest.java | 328 - .../baidu/hugegraph/unit/core/SerialEnumTest.java | 45 - .../hugegraph/unit/core/SystemSchemaStoreTest.java | 59 - .../hugegraph/unit/core/TraversalUtilTest.java | 341 - .../com/baidu/hugegraph/unit/id/EdgeIdTest.java | 119 - .../java/com/baidu/hugegraph/unit/id/IdTest.java | 225 - .../com/baidu/hugegraph/unit/id/IdUtilTest.java | 160 - .../hugegraph/unit/id/SplicingIdGeneratorTest.java | 112 - .../baidu/hugegraph/unit/mysql/MysqlUtilTest.java | 62 - .../hugegraph/unit/mysql/WhereBuilderTest.java | 125 - .../unit/rocksdb/BaseRocksDBUnitTest.java | 131 - .../unit/rocksdb/RocksDBCountersTest.java | 126 - .../hugegraph/unit/rocksdb/RocksDBPerfTest.java | 253 - .../hugegraph/unit/rocksdb/RocksDBSessionTest.java | 655 -- .../unit/rocksdb/RocksDBSessionsTest.java | 223 - .../unit/serializer/BinaryBackendEntryTest.java | 115 - .../serializer/BinaryScatterSerializerTest.java | 94 - .../unit/serializer/BinarySerializerTest.java | 133 - .../hugegraph/unit/serializer/BytesBufferTest.java | 1078 --- .../unit/serializer/SerializerFactoryTest.java | 97 - .../unit/serializer/StoreSerializerTest.java | 92 - .../unit/serializer/TableBackendEntryTest.java | 194 - .../unit/serializer/TextBackendEntryTest.java | 96 - .../hugegraph/unit/util/CompressUtilTest.java | 135 - .../baidu/hugegraph/unit/util/JsonUtilTest.java | 312 - .../baidu/hugegraph/unit/util/RateLimiterTest.java | 174 - .../hugegraph/unit/util/StringEncodingTest.java | 186 - .../com/baidu/hugegraph/unit/util/VersionTest.java | 44 - .../util/collection/CollectionFactoryTest.java | 387 - .../hugegraph/unit/util/collection/IdSetTest.java | 327 - .../unit/util/collection/Int2IntsMapTest.java | 196 - .../hugegraph/unit/util/collection/IntMapTest.java | 424 - .../hugegraph/unit/util/collection/IntSetTest.java | 185 - .../unit/util/collection/ObjectIntMappingTest.java | 143 - .../org/apache/hugegraph/api/ApiTestSuite.java | 52 + .../java/org/apache/hugegraph/api/BaseApiTest.java | 648 ++ .../org/apache/hugegraph/api/CypherApiTest.java | 86 + .../java/org/apache/hugegraph/api/EdgeApiTest.java | 209 + .../org/apache/hugegraph/api/EdgeLabelApiTest.java | 140 + .../org/apache/hugegraph/api/GremlinApiTest.java | 224 + .../apache/hugegraph/api/IndexLabelApiTest.java | 157 + .../org/apache/hugegraph/api/LoginApiTest.java | 170 + .../org/apache/hugegraph/api/MetricsApiTest.java | 292 + .../org/apache/hugegraph/api/ProjectApiTest.java | 264 + .../apache/hugegraph/api/PropertyKeyApiTest.java | 91 + .../org/apache/hugegraph/api/SchemaApiTest.java | 39 + .../java/org/apache/hugegraph/api/TaskApiTest.java | 167 + .../java/org/apache/hugegraph/api/UserApiTest.java | 183 + .../org/apache/hugegraph/api/VertexApiTest.java | 102 + .../apache/hugegraph/api/VertexLabelApiTest.java | 127 + .../api/traversers/AdamicAdarAPITest.java | 58 + .../api/traversers/AllShortestPathsApiTest.java | 66 + .../hugegraph/api/traversers/CountApiTest.java | 62 + .../api/traversers/CrosspointsApiTest.java | 62 + .../traversers/CustomizedCrosspointsApiTest.java | 67 + .../hugegraph/api/traversers/EdgesApiTest.java | 91 + .../api/traversers/FusiformSimilarityApiTest.java | 74 + .../api/traversers/JaccardSimilarityApiTest.java | 86 + .../hugegraph/api/traversers/KneighborApiTest.java | 87 + .../hugegraph/api/traversers/KoutApiTest.java | 101 + .../traversers/MultiNodeShortestPathApiTest.java | 68 + .../api/traversers/NeighborRankApiTest.java | 59 + .../hugegraph/api/traversers/PathsApiTest.java | 87 + .../api/traversers/PersonalRankApiTest.java | 58 + .../hugegraph/api/traversers/RaysApiTest.java | 65 + .../api/traversers/ResourceAllocationAPITest.java | 58 + .../hugegraph/api/traversers/RingsApiTest.java | 59 + .../api/traversers/SameNeighborsApiTest.java | 62 + .../api/traversers/ShortestPathApiTest.java | 63 + .../SingleSourceShortestPathApiTest.java | 57 + .../api/traversers/TemplatePathsApiTest.java | 88 + .../api/traversers/TraversersApiTestSuite.java | 51 + .../traversers/WeightedShortestPathApiTest.java | 68 + .../java/org/apache/hugegraph/core/AuthTest.java | 1578 ++++ .../org/apache/hugegraph/core/BaseCoreTest.java | 125 + .../org/apache/hugegraph/core/CoreTestSuite.java | 97 + .../org/apache/hugegraph/core/EdgeCoreTest.java | 7530 ++++++++++++++++ .../apache/hugegraph/core/EdgeLabelCoreTest.java | 1387 +++ .../apache/hugegraph/core/IndexLabelCoreTest.java | 1887 ++++ .../org/apache/hugegraph/core/MultiGraphsTest.java | 415 + .../apache/hugegraph/core/PropertyCoreTest.java | 804 ++ .../apache/hugegraph/core/PropertyKeyCoreTest.java | 726 ++ .../org/apache/hugegraph/core/RamTableTest.java | 837 ++ .../org/apache/hugegraph/core/RestoreCoreTest.java | 728 ++ .../core/RoleElectionStateMachineTest.java | 325 + .../org/apache/hugegraph/core/SchemaCoreTest.java | 163 + .../org/apache/hugegraph/core/TaskCoreTest.java | 714 ++ .../org/apache/hugegraph/core/VertexCoreTest.java | 9343 ++++++++++++++++++++ .../apache/hugegraph/core/VertexLabelCoreTest.java | 1220 +++ .../org/apache/hugegraph/testutil/FakeObjects.java | 86 + .../java/org/apache/hugegraph/testutil/Utils.java | 112 + .../hugegraph/tinkerpop/ProcessBasicSuite.java | 301 + .../hugegraph/tinkerpop/ProcessStandardTest.java | 29 + .../tinkerpop/ProcessTestGraphProvider.java | 31 + .../hugegraph/tinkerpop/StructureBasicSuite.java | 126 + .../hugegraph/tinkerpop/StructureStandardTest.java | 29 + .../tinkerpop/StructureTestGraphProvider.java | 31 + .../org/apache/hugegraph/tinkerpop/TestGraph.java | 951 ++ .../hugegraph/tinkerpop/TestGraphFactory.java | 30 + .../hugegraph/tinkerpop/TestGraphProvider.java | 448 + .../tinkerpop/tests/HugeGraphWriteTest.java | 49 + .../org/apache/hugegraph/unit/BaseUnitTest.java | 85 + .../org/apache/hugegraph/unit/FakeObjects.java | 216 + .../org/apache/hugegraph/unit/UnitTestSuite.java | 156 + .../hugegraph/unit/cache/CacheManagerTest.java | 315 + .../org/apache/hugegraph/unit/cache/CacheTest.java | 774 ++ .../unit/cache/CachedGraphTransactionTest.java | 224 + .../unit/cache/CachedSchemaTransactionTest.java | 203 + .../apache/hugegraph/unit/cache/RamTableTest.java | 284 + .../hugegraph/unit/cassandra/CassandraTest.java | 197 + .../apache/hugegraph/unit/core/AnalyzerTest.java | 206 + .../hugegraph/unit/core/BackendMutationTest.java | 358 + .../hugegraph/unit/core/BackendStoreInfoTest.java | 50 + .../unit/core/ConditionQueryFlattenTest.java | 262 + .../apache/hugegraph/unit/core/ConditionTest.java | 647 ++ .../apache/hugegraph/unit/core/DataTypeTest.java | 88 + .../apache/hugegraph/unit/core/DirectionsTest.java | 79 + .../apache/hugegraph/unit/core/ExceptionTest.java | 45 + .../apache/hugegraph/unit/core/LocksTableTest.java | 309 + .../apache/hugegraph/unit/core/PageStateTest.java | 90 + .../org/apache/hugegraph/unit/core/QueryTest.java | 171 + .../org/apache/hugegraph/unit/core/RangeTest.java | 172 + .../hugegraph/unit/core/RolePermissionTest.java | 584 ++ .../apache/hugegraph/unit/core/RowLockTest.java | 101 + .../hugegraph/unit/core/SecurityManagerTest.java | 328 + .../apache/hugegraph/unit/core/SerialEnumTest.java | 45 + .../hugegraph/unit/core/SystemSchemaStoreTest.java | 59 + .../hugegraph/unit/core/TraversalUtilTest.java | 341 + .../org/apache/hugegraph/unit/id/EdgeIdTest.java | 119 + .../java/org/apache/hugegraph/unit/id/IdTest.java | 225 + .../org/apache/hugegraph/unit/id/IdUtilTest.java | 160 + .../hugegraph/unit/id/SplicingIdGeneratorTest.java | 112 + .../apache/hugegraph/unit/mysql/MysqlUtilTest.java | 62 + .../hugegraph/unit/mysql/WhereBuilderTest.java | 125 + .../unit/rocksdb/BaseRocksDBUnitTest.java | 131 + .../unit/rocksdb/RocksDBCountersTest.java | 126 + .../hugegraph/unit/rocksdb/RocksDBPerfTest.java | 253 + .../hugegraph/unit/rocksdb/RocksDBSessionTest.java | 655 ++ .../unit/rocksdb/RocksDBSessionsTest.java | 223 + .../unit/serializer/BinaryBackendEntryTest.java | 115 + .../serializer/BinaryScatterSerializerTest.java | 94 + .../unit/serializer/BinarySerializerTest.java | 133 + .../hugegraph/unit/serializer/BytesBufferTest.java | 1078 +++ .../unit/serializer/SerializerFactoryTest.java | 97 + .../unit/serializer/StoreSerializerTest.java | 92 + .../unit/serializer/TableBackendEntryTest.java | 194 + .../unit/serializer/TextBackendEntryTest.java | 96 + .../hugegraph/unit/util/CompressUtilTest.java | 137 + .../apache/hugegraph/unit/util/JsonUtilTest.java | 312 + .../hugegraph/unit/util/RateLimiterTest.java | 174 + .../hugegraph/unit/util/StringEncodingTest.java | 186 + .../apache/hugegraph/unit/util/VersionTest.java | 44 + .../util/collection/CollectionFactoryTest.java | 389 + .../hugegraph/unit/util/collection/IdSetTest.java | 327 + .../unit/util/collection/Int2IntsMapTest.java | 196 + .../hugegraph/unit/util/collection/IntMapTest.java | 424 + .../hugegraph/unit/util/collection/IntSetTest.java | 185 + .../unit/util/collection/ObjectIntMappingTest.java | 143 + .../src/main/resources/hugegraph.properties | 2 +- hugegraph-test/src/main/resources/log4j2.xml | 6 +- pom.xml | 111 +- 1377 files changed, 166759 insertions(+), 166968 deletions(-) diff --cc hugegraph-hbase/pom.xml index 7ffc51dc3,37cdaecdc..3c49fe9e2 --- a/hugegraph-hbase/pom.xml +++ b/hugegraph-hbase/pom.xml @@@ -27,89 -28,21 +28,93 @@@ <artifactId>hugegraph-hbase</artifactId> + <properties> + <hugegraph-core-version>1.0.0</hugegraph-core-version> + </properties> + <dependencies> <dependency> - <groupId>com.baidu.hugegraph</groupId> + <groupId>org.apache.hugegraph</groupId> <artifactId>hugegraph-core</artifactId> - <version>${project.version}</version> + <version>${hugegraph-core-version}</version> </dependency> <dependency> - <groupId>com.baidu.hugegraph</groupId> - <artifactId>hbase-shaded-endpoint</artifactId> - <version>2.0.6</version> + <groupId>org.apache.hbase</groupId> + <artifactId>hbase-endpoint</artifactId> + <version>3.0.0-alpha-3</version> <exclusions> + <exclusion> + <groupId>org.apache.hbase</groupId> + <artifactId>hbase-server</artifactId> + </exclusion> + <exclusion> + <groupId>org.apache.hbase</groupId> + <artifactId>hbase-hadoop2-compat</artifactId> + </exclusion> + <exclusion> + <groupId>org.apache.hadoop</groupId> + <artifactId>hadoop-hdfs</artifactId> + </exclusion> + <exclusion> + <groupId>org.apache.hadoop</groupId> + <artifactId>hadoop-yarn-api</artifactId> + </exclusion> + <exclusion> + <groupId>org.apache.hadoop</groupId> + <artifactId>hadoop-client</artifactId> + </exclusion> + <exclusion> + <groupId>org.apache.hadoop</groupId> + <artifactId>hadoop-mapreduce-client-core</artifactId> + </exclusion> + <exclusion> + <groupId>org.apache.hadoop</groupId> + <artifactId>hadoop-mapreduce-client-jobclient</artifactId> + </exclusion> + <exclusion> + <groupId>org.apache.hadoop</groupId> + <artifactId>hadoop-client</artifactId> + </exclusion> + <exclusion> + <groupId>com.sun.jersey</groupId> + <artifactId>jersey-core</artifactId> + </exclusion> + <exclusion> + <groupId>com.sun.jersey</groupId> + <artifactId>jersey-server</artifactId> + </exclusion> + <exclusion> + <groupId>com.sun.jersey</groupId> + <artifactId>jersey-json</artifactId> + </exclusion> + <exclusion> + <groupId>com.sun.jersey</groupId> + <artifactId>jersey-client</artifactId> + </exclusion> + <exclusion> + <groupId>com.sun.jersey.contribs</groupId> + <artifactId>jersey-guice</artifactId> + </exclusion> + <exclusion> + <groupId>javax.servlet</groupId> + <artifactId>servlet-api</artifactId> + </exclusion> + <exclusion> + <groupId>javax.servlet.jsp</groupId> + <artifactId>jsp-api</artifactId> + </exclusion> + <exclusion> + <groupId>com.fasterxml.jackson.core</groupId> + <artifactId>jackson-databind</artifactId> + </exclusion> + <exclusion> + <groupId>org.slf4j</groupId> + <artifactId>slf4j-api</artifactId> + </exclusion> + <exclusion> + <groupId>org.slf4j</groupId> + <artifactId>slf4j-log4j12</artifactId> + </exclusion> <exclusion> <groupId>log4j</groupId> <artifactId>log4j</artifactId>
