diff --git a/hg-store-cli/src/main/java/org/apache/hugegraph/store/cli/AppConfig.java b/hg-store-cli/src/main/java/org/apache/hugegraph/store/cli/AppConfig.java index 4b0e5fac1..5a6cf4d2e 100644 --- a/hg-store-cli/src/main/java/org/apache/hugegraph/store/cli/AppConfig.java +++ b/hg-store-cli/src/main/java/org/apache/hugegraph/store/cli/AppConfig.java @@ -22,9 +22,6 @@ import org.springframework.stereotype.Component; import lombok.Data; -/** - * @author lynn.bond@hotmail.com on 2022/2/15 - */ @Data @Component public class AppConfig { diff --git a/hg-store-cli/src/main/java/org/apache/hugegraph/store/cli/StoreConsoleApplication.java b/hg-store-cli/src/main/java/org/apache/hugegraph/store/cli/StoreConsoleApplication.java index 2a07e867f..1a620b27f 100644 --- a/hg-store-cli/src/main/java/org/apache/hugegraph/store/cli/StoreConsoleApplication.java +++ b/hg-store-cli/src/main/java/org/apache/hugegraph/store/cli/StoreConsoleApplication.java @@ -35,7 +35,7 @@ import lombok.extern.slf4j.Slf4j; /** - * @author lynn.bond@hotmail.com on 2022/2/14 + * 2022/2/14 */ @SpringBootApplication @Slf4j diff --git a/hg-store-cli/src/main/java/org/apache/hugegraph/store/cli/scan/GrpcShardScanner.java b/hg-store-cli/src/main/java/org/apache/hugegraph/store/cli/scan/GrpcShardScanner.java index 3ee571d36..deaacc63f 100644 --- a/hg-store-cli/src/main/java/org/apache/hugegraph/store/cli/scan/GrpcShardScanner.java +++ b/hg-store-cli/src/main/java/org/apache/hugegraph/store/cli/scan/GrpcShardScanner.java @@ -37,7 +37,6 @@ import io.grpc.stub.StreamObserver; import lombok.extern.slf4j.Slf4j; /** - * @author zhangyingjie * @date 2022/11/1 **/ diff --git a/hg-store-cli/src/main/java/org/apache/hugegraph/store/cli/scan/HgStoreCommitter.java b/hg-store-cli/src/main/java/org/apache/hugegraph/store/cli/scan/HgStoreCommitter.java index 50f3d87b6..3161d7419 100644 --- a/hg-store-cli/src/main/java/org/apache/hugegraph/store/cli/scan/HgStoreCommitter.java +++ b/hg-store-cli/src/main/java/org/apache/hugegraph/store/cli/scan/HgStoreCommitter.java @@ -24,7 +24,7 @@ import org.apache.hugegraph.store.cli.util.HgCliUtil; import org.apache.hugegraph.store.client.HgStoreNodeManager; /** - * @author lynn.bond@hotmail.com on 2022/2/28 + * 2022/2/28 */ public class HgStoreCommitter { diff --git a/hg-store-cli/src/main/java/org/apache/hugegraph/store/cli/scan/HgStoreScanner.java b/hg-store-cli/src/main/java/org/apache/hugegraph/store/cli/scan/HgStoreScanner.java index c023e6487..c02956df4 100644 --- a/hg-store-cli/src/main/java/org/apache/hugegraph/store/cli/scan/HgStoreScanner.java +++ b/hg-store-cli/src/main/java/org/apache/hugegraph/store/cli/scan/HgStoreScanner.java @@ -39,7 +39,7 @@ import org.apache.hugegraph.store.client.util.MetricX; import lombok.extern.slf4j.Slf4j; /** - * @author lynn.bond@hotmail.com on 2022/2/14 + * 2022/2/14 */ @Slf4j public class HgStoreScanner { diff --git a/hg-store-cli/src/main/java/org/apache/hugegraph/store/cli/util/HgCliUtil.java b/hg-store-cli/src/main/java/org/apache/hugegraph/store/cli/util/HgCliUtil.java index fb1828c3e..05f8a056a 100644 --- a/hg-store-cli/src/main/java/org/apache/hugegraph/store/cli/util/HgCliUtil.java +++ b/hg-store-cli/src/main/java/org/apache/hugegraph/store/cli/util/HgCliUtil.java @@ -33,7 +33,7 @@ import org.apache.hugegraph.store.client.util.HgStoreClientConst; /** - * @author lynn.bond@hotmail.com on 2022/2/14 + * 2022/2/14 */ public class HgCliUtil { diff --git a/hg-store-cli/src/main/java/org/apache/hugegraph/store/cli/util/HgMetricX.java b/hg-store-cli/src/main/java/org/apache/hugegraph/store/cli/util/HgMetricX.java index e30c65433..0586aa09c 100644 --- a/hg-store-cli/src/main/java/org/apache/hugegraph/store/cli/util/HgMetricX.java +++ b/hg-store-cli/src/main/java/org/apache/hugegraph/store/cli/util/HgMetricX.java @@ -18,7 +18,7 @@ package org.apache.hugegraph.store.cli.util; /** - * @author lynn.bond@hotmail.com on 2022/1/29 + * 2022/1/29 */ public class HgMetricX { private long start; diff --git a/hg-store-client/src/main/java/org/apache/hugegraph/store/HgKvEntry.java b/hg-store-client/src/main/java/org/apache/hugegraph/store/HgKvEntry.java index 2483268bc..ed07167b2 100644 --- a/hg-store-client/src/main/java/org/apache/hugegraph/store/HgKvEntry.java +++ b/hg-store-client/src/main/java/org/apache/hugegraph/store/HgKvEntry.java @@ -17,9 +17,7 @@ package org.apache.hugegraph.store; -/** - * @author lynn.bond@hotmail.com - */ + public interface HgKvEntry { byte[] key(); diff --git a/hg-store-client/src/main/java/org/apache/hugegraph/store/HgKvIterator.java b/hg-store-client/src/main/java/org/apache/hugegraph/store/HgKvIterator.java index 62b29a5ce..29842beee 100644 --- a/hg-store-client/src/main/java/org/apache/hugegraph/store/HgKvIterator.java +++ b/hg-store-client/src/main/java/org/apache/hugegraph/store/HgKvIterator.java @@ -21,7 +21,7 @@ import java.io.Closeable; import java.util.Iterator; /** - * @author lynn.bond@hotmail.com created on 2021/10/21 + * created on 2021/10/21 */ public interface HgKvIterator extends Iterator, HgSeekAble, Closeable { diff --git a/hg-store-client/src/main/java/org/apache/hugegraph/store/HgKvOrderedIterator.java b/hg-store-client/src/main/java/org/apache/hugegraph/store/HgKvOrderedIterator.java index 1e315d581..1c656f16f 100644 --- a/hg-store-client/src/main/java/org/apache/hugegraph/store/HgKvOrderedIterator.java +++ b/hg-store-client/src/main/java/org/apache/hugegraph/store/HgKvOrderedIterator.java @@ -18,7 +18,7 @@ package org.apache.hugegraph.store; /** - * @author lynn.bond@hotmail.com created on 2022/03/10 + * created on 2022/03/10 */ public interface HgKvOrderedIterator extends HgKvIterator, Comparable { long getSequence(); diff --git a/hg-store-client/src/main/java/org/apache/hugegraph/store/HgKvPagingIterator.java b/hg-store-client/src/main/java/org/apache/hugegraph/store/HgKvPagingIterator.java index abf50b0d9..6d43d8f68 100644 --- a/hg-store-client/src/main/java/org/apache/hugegraph/store/HgKvPagingIterator.java +++ b/hg-store-client/src/main/java/org/apache/hugegraph/store/HgKvPagingIterator.java @@ -18,7 +18,7 @@ package org.apache.hugegraph.store; /** - * @author lynn.bond@hotmail.com created on 2021/10/24 + * created on 2021/10/24 */ public interface HgKvPagingIterator extends HgKvIterator, HgPageSize { } diff --git a/hg-store-client/src/main/java/org/apache/hugegraph/store/HgKvStore.java b/hg-store-client/src/main/java/org/apache/hugegraph/store/HgKvStore.java index 97848d9d1..fd1e48367 100644 --- a/hg-store-client/src/main/java/org/apache/hugegraph/store/HgKvStore.java +++ b/hg-store-client/src/main/java/org/apache/hugegraph/store/HgKvStore.java @@ -23,7 +23,6 @@ import org.apache.hugegraph.store.client.grpc.KvCloseableIterator; import org.apache.hugegraph.store.grpc.stream.ScanStreamReq; /** - * @author lynn.bond@hotmail.com * @version 0.2.0 */ public interface HgKvStore { diff --git a/hg-store-client/src/main/java/org/apache/hugegraph/store/HgOwnerKey.java b/hg-store-client/src/main/java/org/apache/hugegraph/store/HgOwnerKey.java index 44dad22e4..c4d78f48e 100644 --- a/hg-store-client/src/main/java/org/apache/hugegraph/store/HgOwnerKey.java +++ b/hg-store-client/src/main/java/org/apache/hugegraph/store/HgOwnerKey.java @@ -26,7 +26,8 @@ import java.util.Arrays; import org.apache.hugegraph.store.client.util.HgStoreClientUtil; /** - * @author lynn.bond@hotmail.com created on 2021/10/14 + * created on 2021/10/14 + * * @version 1.3.0 add canceled assert */ public class HgOwnerKey implements Serializable { diff --git a/hg-store-client/src/main/java/org/apache/hugegraph/store/HgPageSize.java b/hg-store-client/src/main/java/org/apache/hugegraph/store/HgPageSize.java index aa01b7710..25296f459 100644 --- a/hg-store-client/src/main/java/org/apache/hugegraph/store/HgPageSize.java +++ b/hg-store-client/src/main/java/org/apache/hugegraph/store/HgPageSize.java @@ -19,8 +19,8 @@ package org.apache.hugegraph.store; /** * Return the amount of records returned by one query in pageable-query. - * - * @author lynn.bond@hotmail.com created on 2021/10/24 + *

+ * created on 2021/10/24 */ public interface HgPageSize { long getPageSize(); diff --git a/hg-store-client/src/main/java/org/apache/hugegraph/store/HgPrivate.java b/hg-store-client/src/main/java/org/apache/hugegraph/store/HgPrivate.java index 8da436912..e6fe6170f 100644 --- a/hg-store-client/src/main/java/org/apache/hugegraph/store/HgPrivate.java +++ b/hg-store-client/src/main/java/org/apache/hugegraph/store/HgPrivate.java @@ -17,18 +17,16 @@ package org.apache.hugegraph.store; -/** - * @author lynn.bond@hotmail.com - */ + public final class HgPrivate { - private static final HgPrivate instance = new HgPrivate(); + private static final HgPrivate INSTANCE = new HgPrivate(); private HgPrivate() { } static HgPrivate of() { - return instance; + return INSTANCE; } } diff --git a/hg-store-client/src/main/java/org/apache/hugegraph/store/HgScanQuery.java b/hg-store-client/src/main/java/org/apache/hugegraph/store/HgScanQuery.java index d54c8dbef..810155ef2 100644 --- a/hg-store-client/src/main/java/org/apache/hugegraph/store/HgScanQuery.java +++ b/hg-store-client/src/main/java/org/apache/hugegraph/store/HgScanQuery.java @@ -25,7 +25,8 @@ import org.apache.hugegraph.store.client.util.HgAssert; import org.apache.hugegraph.store.grpc.common.ScanOrderType; /** - * @author lynn.bond@hotmail.com on 2022/3/4 + * 2022/3/4 + * * @version 0.5.0 */ public interface HgScanQuery { diff --git a/hg-store-client/src/main/java/org/apache/hugegraph/store/HgSeekAble.java b/hg-store-client/src/main/java/org/apache/hugegraph/store/HgSeekAble.java index 32114fd9e..87cfe0168 100644 --- a/hg-store-client/src/main/java/org/apache/hugegraph/store/HgSeekAble.java +++ b/hg-store-client/src/main/java/org/apache/hugegraph/store/HgSeekAble.java @@ -18,7 +18,7 @@ package org.apache.hugegraph.store; /** - * @author lynn.bond@hotmail.com created on 2022/03/11 + * created on 2022/03/11 */ public interface HgSeekAble { byte[] position(); diff --git a/hg-store-client/src/main/java/org/apache/hugegraph/store/HgSessionManager.java b/hg-store-client/src/main/java/org/apache/hugegraph/store/HgSessionManager.java index 4189d46b3..237930187 100644 --- a/hg-store-client/src/main/java/org/apache/hugegraph/store/HgSessionManager.java +++ b/hg-store-client/src/main/java/org/apache/hugegraph/store/HgSessionManager.java @@ -25,8 +25,6 @@ import org.apache.hugegraph.store.client.HgStoreSessionProvider; * Maintain HgStoreSession instances. * // TODO: Holding more than one HgSessionManager is available,if you want to connect multi * HgStore-clusters. - * - * @author lynn.bond@hotmail.com */ @ThreadSafe diff --git a/hg-store-client/src/main/java/org/apache/hugegraph/store/HgSessionProvider.java b/hg-store-client/src/main/java/org/apache/hugegraph/store/HgSessionProvider.java index ccdb20066..75cbbfd20 100644 --- a/hg-store-client/src/main/java/org/apache/hugegraph/store/HgSessionProvider.java +++ b/hg-store-client/src/main/java/org/apache/hugegraph/store/HgSessionProvider.java @@ -20,7 +20,7 @@ package org.apache.hugegraph.store; import javax.annotation.concurrent.ThreadSafe; /** - * @author lynn.bond@hotmail.com created on 2021/10/12 + * created on 2021/10/12 */ @ThreadSafe public interface HgSessionProvider { diff --git a/hg-store-client/src/main/java/org/apache/hugegraph/store/HgStoreClient.java b/hg-store-client/src/main/java/org/apache/hugegraph/store/HgStoreClient.java index 561d0a474..ca139b850 100644 --- a/hg-store-client/src/main/java/org/apache/hugegraph/store/HgStoreClient.java +++ b/hg-store-client/src/main/java/org/apache/hugegraph/store/HgStoreClient.java @@ -29,8 +29,6 @@ import org.apache.hugegraph.store.client.HgStoreSessionProvider; * Maintain HgStoreSession instances. * // TODO: Holding more than one HgSessionManager is available,if you want to connect multi * HgStore-clusters. - * - * @author lynn.bond@hotmail.com */ @ThreadSafe diff --git a/hg-store-client/src/main/java/org/apache/hugegraph/store/HgStoreSession.java b/hg-store-client/src/main/java/org/apache/hugegraph/store/HgStoreSession.java index 860d58f8c..b3599dedd 100644 --- a/hg-store-client/src/main/java/org/apache/hugegraph/store/HgStoreSession.java +++ b/hg-store-client/src/main/java/org/apache/hugegraph/store/HgStoreSession.java @@ -19,9 +19,7 @@ package org.apache.hugegraph.store; import org.apache.hugegraph.store.client.type.HgStoreClientException; -/** - * @author lynn.bond@hotmail.com - */ + public interface HgStoreSession extends HgKvStore { void beginTx(); diff --git a/hg-store-client/src/main/java/org/apache/hugegraph/store/HgTkvEntry.java b/hg-store-client/src/main/java/org/apache/hugegraph/store/HgTkvEntry.java index c13d529ab..50220abe3 100644 --- a/hg-store-client/src/main/java/org/apache/hugegraph/store/HgTkvEntry.java +++ b/hg-store-client/src/main/java/org/apache/hugegraph/store/HgTkvEntry.java @@ -17,9 +17,7 @@ package org.apache.hugegraph.store; -/** - * @author lynn.bond@hotmail.com - */ + public interface HgTkvEntry { String table(); diff --git a/hg-store-client/src/main/java/org/apache/hugegraph/store/HgTokvEntry.java b/hg-store-client/src/main/java/org/apache/hugegraph/store/HgTokvEntry.java index 6b51bfdbf..3c2c765af 100644 --- a/hg-store-client/src/main/java/org/apache/hugegraph/store/HgTokvEntry.java +++ b/hg-store-client/src/main/java/org/apache/hugegraph/store/HgTokvEntry.java @@ -17,9 +17,7 @@ package org.apache.hugegraph.store; -/** - * @author lynn.bond@hotmail.com - */ + public interface HgTokvEntry { String table(); diff --git a/hg-store-client/src/main/java/org/apache/hugegraph/store/client/HgNodePartition.java b/hg-store-client/src/main/java/org/apache/hugegraph/store/client/HgNodePartition.java index bf6178f78..d060f2c0c 100644 --- a/hg-store-client/src/main/java/org/apache/hugegraph/store/client/HgNodePartition.java +++ b/hg-store-client/src/main/java/org/apache/hugegraph/store/client/HgNodePartition.java @@ -21,8 +21,8 @@ import java.util.Objects; /** * Immutable Object Pattern - * - * @author lynn.bond@hotmail.com created on 2021/10/26 + *

+ * created on 2021/10/26 */ public final class HgNodePartition { private final Long nodeId; diff --git a/hg-store-client/src/main/java/org/apache/hugegraph/store/client/HgNodePartitionerBuilder.java b/hg-store-client/src/main/java/org/apache/hugegraph/store/client/HgNodePartitionerBuilder.java index a89647753..d0042e9bb 100644 --- a/hg-store-client/src/main/java/org/apache/hugegraph/store/client/HgNodePartitionerBuilder.java +++ b/hg-store-client/src/main/java/org/apache/hugegraph/store/client/HgNodePartitionerBuilder.java @@ -26,7 +26,8 @@ import java.util.Set; import javax.annotation.concurrent.NotThreadSafe; /** - * @author lynn.bond@hotmail.com created on 2021/10/26 + * created on 2021/10/26 + * * @version 1.0.0 */ @NotThreadSafe diff --git a/hg-store-client/src/main/java/org/apache/hugegraph/store/client/HgPrivate.java b/hg-store-client/src/main/java/org/apache/hugegraph/store/client/HgPrivate.java index 7487e48f2..597f13fb9 100644 --- a/hg-store-client/src/main/java/org/apache/hugegraph/store/client/HgPrivate.java +++ b/hg-store-client/src/main/java/org/apache/hugegraph/store/client/HgPrivate.java @@ -18,7 +18,7 @@ package org.apache.hugegraph.store.client; /** - * @author lynn.bond@hotmail.com created on 2021/10/26 + * created on 2021/10/26 */ public class HgPrivate { private final static HgPrivate instance = new HgPrivate(); diff --git a/hg-store-client/src/main/java/org/apache/hugegraph/store/client/HgStoreNode.java b/hg-store-client/src/main/java/org/apache/hugegraph/store/client/HgStoreNode.java index e75a99371..da9d3aa3d 100644 --- a/hg-store-client/src/main/java/org/apache/hugegraph/store/client/HgStoreNode.java +++ b/hg-store-client/src/main/java/org/apache/hugegraph/store/client/HgStoreNode.java @@ -20,7 +20,8 @@ package org.apache.hugegraph.store.client; import org.apache.hugegraph.store.HgStoreSession; /** - * @author lynn.bond@hotmail.com created on 2021/10/11 + * created on 2021/10/11 + * * @version 0.2.0 */ public interface HgStoreNode { diff --git a/hg-store-client/src/main/java/org/apache/hugegraph/store/client/HgStoreNodeBuilder.java b/hg-store-client/src/main/java/org/apache/hugegraph/store/client/HgStoreNodeBuilder.java index 377ecf469..46833d82a 100644 --- a/hg-store-client/src/main/java/org/apache/hugegraph/store/client/HgStoreNodeBuilder.java +++ b/hg-store-client/src/main/java/org/apache/hugegraph/store/client/HgStoreNodeBuilder.java @@ -18,7 +18,7 @@ package org.apache.hugegraph.store.client; /** - * @author lynn.bond@hotmail.com created on 2021/10/11 + * created on 2021/10/11 */ public interface HgStoreNodeBuilder { diff --git a/hg-store-client/src/main/java/org/apache/hugegraph/store/client/HgStoreNodeCandidates.java b/hg-store-client/src/main/java/org/apache/hugegraph/store/client/HgStoreNodeCandidates.java index b69f53035..54e7e5950 100644 --- a/hg-store-client/src/main/java/org/apache/hugegraph/store/client/HgStoreNodeCandidates.java +++ b/hg-store-client/src/main/java/org/apache/hugegraph/store/client/HgStoreNodeCandidates.java @@ -20,7 +20,7 @@ package org.apache.hugegraph.store.client; import java.util.List; /** - * @author lynn.bond@hotmail.com created on 2021/10/12 + * created on 2021/10/12 */ public final class HgStoreNodeCandidates { diff --git a/hg-store-client/src/main/java/org/apache/hugegraph/store/client/HgStoreNodeManager.java b/hg-store-client/src/main/java/org/apache/hugegraph/store/client/HgStoreNodeManager.java index 6f3d283a0..1f0abb43e 100644 --- a/hg-store-client/src/main/java/org/apache/hugegraph/store/client/HgStoreNodeManager.java +++ b/hg-store-client/src/main/java/org/apache/hugegraph/store/client/HgStoreNodeManager.java @@ -36,8 +36,9 @@ import lombok.extern.slf4j.Slf4j; /** * // TODO: Mapping to Store-Node-Cluster, one to one. + *

+ * created on 2021/10/11 * - * @author lynn.bond@hotmail.com created on 2021/10/11 * @version 0.2.0 */ @ThreadSafe diff --git a/hg-store-client/src/main/java/org/apache/hugegraph/store/client/HgStoreNodeNotifier.java b/hg-store-client/src/main/java/org/apache/hugegraph/store/client/HgStoreNodeNotifier.java index cae2b49e1..91d3c6e3c 100644 --- a/hg-store-client/src/main/java/org/apache/hugegraph/store/client/HgStoreNodeNotifier.java +++ b/hg-store-client/src/main/java/org/apache/hugegraph/store/client/HgStoreNodeNotifier.java @@ -18,7 +18,8 @@ package org.apache.hugegraph.store.client; /** - * @author lynn.bond@hotmail.com created on 2021/10/12 + * created on 2021/10/12 + * * @version 1.0.0 */ public interface HgStoreNodeNotifier { diff --git a/hg-store-client/src/main/java/org/apache/hugegraph/store/client/HgStoreNodePartitioner.java b/hg-store-client/src/main/java/org/apache/hugegraph/store/client/HgStoreNodePartitioner.java index a6c7393b6..23ac8f95d 100644 --- a/hg-store-client/src/main/java/org/apache/hugegraph/store/client/HgStoreNodePartitioner.java +++ b/hg-store-client/src/main/java/org/apache/hugegraph/store/client/HgStoreNodePartitioner.java @@ -20,7 +20,8 @@ package org.apache.hugegraph.store.client; import org.apache.hugegraph.store.client.util.HgStoreClientConst; /** - * @author lynn.bond@hotmail.com created on 2021/10/12 + * created on 2021/10/12 + * * @version 1.0.0 */ public interface HgStoreNodePartitioner { diff --git a/hg-store-client/src/main/java/org/apache/hugegraph/store/client/HgStoreNodeProvider.java b/hg-store-client/src/main/java/org/apache/hugegraph/store/client/HgStoreNodeProvider.java index 7fc1ef86a..46d78fd6c 100644 --- a/hg-store-client/src/main/java/org/apache/hugegraph/store/client/HgStoreNodeProvider.java +++ b/hg-store-client/src/main/java/org/apache/hugegraph/store/client/HgStoreNodeProvider.java @@ -18,7 +18,7 @@ package org.apache.hugegraph.store.client; /** - * @author lynn.bond@hotmail.com created on 2021/10/27 + * created on 2021/10/27 */ public interface HgStoreNodeProvider { diff --git a/hg-store-client/src/main/java/org/apache/hugegraph/store/client/HgStoreNodeSession.java b/hg-store-client/src/main/java/org/apache/hugegraph/store/client/HgStoreNodeSession.java index fcc086db6..73872dfc5 100644 --- a/hg-store-client/src/main/java/org/apache/hugegraph/store/client/HgStoreNodeSession.java +++ b/hg-store-client/src/main/java/org/apache/hugegraph/store/client/HgStoreNodeSession.java @@ -20,7 +20,8 @@ package org.apache.hugegraph.store.client; import org.apache.hugegraph.store.HgStoreSession; /** - * @author lynn.bond@hotmail.com created on 2021/10/11 + * created on 2021/10/11 + * * @version 0.1.0 */ public interface HgStoreNodeSession extends HgStoreSession { diff --git a/hg-store-client/src/main/java/org/apache/hugegraph/store/client/HgStoreNotice.java b/hg-store-client/src/main/java/org/apache/hugegraph/store/client/HgStoreNotice.java index a52134bb8..6fb4b699a 100644 --- a/hg-store-client/src/main/java/org/apache/hugegraph/store/client/HgStoreNotice.java +++ b/hg-store-client/src/main/java/org/apache/hugegraph/store/client/HgStoreNotice.java @@ -26,7 +26,7 @@ import org.apache.hugegraph.store.client.type.HgNodeStatus; import org.apache.hugegraph.store.client.util.HgAssert; /** - * @author lynn.bond@hotmail.com on 2021/11/16 + * 2021/11/16 */ @NotThreadSafe public class HgStoreNotice { diff --git a/hg-store-client/src/main/java/org/apache/hugegraph/store/client/HgStoreSessionProvider.java b/hg-store-client/src/main/java/org/apache/hugegraph/store/client/HgStoreSessionProvider.java index 2b85848db..26785083e 100644 --- a/hg-store-client/src/main/java/org/apache/hugegraph/store/client/HgStoreSessionProvider.java +++ b/hg-store-client/src/main/java/org/apache/hugegraph/store/client/HgStoreSessionProvider.java @@ -23,7 +23,7 @@ import org.apache.hugegraph.store.HgSessionProvider; import org.apache.hugegraph.store.HgStoreSession; /** - * @author lynn.bond@hotmail.com created on 2021/10/12 + * created on 2021/10/12 */ @ThreadSafe public class HgStoreSessionProvider implements HgSessionProvider { diff --git a/hg-store-client/src/main/java/org/apache/hugegraph/store/client/HgTkvEntryImpl.java b/hg-store-client/src/main/java/org/apache/hugegraph/store/client/HgTkvEntryImpl.java index 7035c058e..5541b7031 100644 --- a/hg-store-client/src/main/java/org/apache/hugegraph/store/client/HgTkvEntryImpl.java +++ b/hg-store-client/src/main/java/org/apache/hugegraph/store/client/HgTkvEntryImpl.java @@ -23,7 +23,7 @@ import java.util.Objects; import org.apache.hugegraph.store.HgTkvEntry; /** - * @author lynn.bond@hotmail.com created on 2021/10/14 + * created on 2021/10/14 */ class HgTkvEntryImpl implements HgTkvEntry { private final String table; diff --git a/hg-store-client/src/main/java/org/apache/hugegraph/store/client/HgTokvEntryImpl.java b/hg-store-client/src/main/java/org/apache/hugegraph/store/client/HgTokvEntryImpl.java index 3867ebbef..a948bc163 100644 --- a/hg-store-client/src/main/java/org/apache/hugegraph/store/client/HgTokvEntryImpl.java +++ b/hg-store-client/src/main/java/org/apache/hugegraph/store/client/HgTokvEntryImpl.java @@ -24,7 +24,7 @@ import org.apache.hugegraph.store.HgOwnerKey; import org.apache.hugegraph.store.HgTokvEntry; /** - * @author lynn.bond@hotmail.com created on 2021/10/14 + * created on 2021/10/14 */ class HgTokvEntryImpl implements HgTokvEntry { diff --git a/hg-store-client/src/main/java/org/apache/hugegraph/store/client/MultiNodeSessionFactory.java b/hg-store-client/src/main/java/org/apache/hugegraph/store/client/MultiNodeSessionFactory.java index 2438cb180..7237e096f 100644 --- a/hg-store-client/src/main/java/org/apache/hugegraph/store/client/MultiNodeSessionFactory.java +++ b/hg-store-client/src/main/java/org/apache/hugegraph/store/client/MultiNodeSessionFactory.java @@ -22,7 +22,7 @@ import javax.annotation.concurrent.ThreadSafe; import org.apache.hugegraph.store.HgStoreSession; /** - * @author lynn.bond@hotmail.com created on 2021/10/12 + * created on 2021/10/12 */ @ThreadSafe public final class MultiNodeSessionFactory { diff --git a/hg-store-client/src/main/java/org/apache/hugegraph/store/client/NodeTkv.java b/hg-store-client/src/main/java/org/apache/hugegraph/store/client/NodeTkv.java index a74cd4f90..00c3faade 100644 --- a/hg-store-client/src/main/java/org/apache/hugegraph/store/client/NodeTkv.java +++ b/hg-store-client/src/main/java/org/apache/hugegraph/store/client/NodeTkv.java @@ -25,7 +25,7 @@ import org.apache.hugegraph.store.HgOwnerKey; import org.apache.hugegraph.store.HgStoreSession; /** - * @author lynn.bond@hotmail.com created on 2021/10/26 + * created on 2021/10/26 */ @ThreadSafe class NodeTkv { diff --git a/hg-store-client/src/main/java/org/apache/hugegraph/store/client/NodeTxExecutor.java b/hg-store-client/src/main/java/org/apache/hugegraph/store/client/NodeTxExecutor.java index 622c06f9f..1d58097c6 100644 --- a/hg-store-client/src/main/java/org/apache/hugegraph/store/client/NodeTxExecutor.java +++ b/hg-store-client/src/main/java/org/apache/hugegraph/store/client/NodeTxExecutor.java @@ -50,7 +50,7 @@ import lombok.extern.slf4j.Slf4j; /** - * @author lynn.bond@hotmail.com on 2021/11/18 + * 2021/11/18 */ @Slf4j @NotThreadSafe diff --git a/hg-store-client/src/main/java/org/apache/hugegraph/store/client/NodeTxSessionProxy.java b/hg-store-client/src/main/java/org/apache/hugegraph/store/client/NodeTxSessionProxy.java index 025224dee..dc850c37d 100644 --- a/hg-store-client/src/main/java/org/apache/hugegraph/store/client/NodeTxSessionProxy.java +++ b/hg-store-client/src/main/java/org/apache/hugegraph/store/client/NodeTxSessionProxy.java @@ -57,7 +57,8 @@ import org.apache.hugegraph.store.term.HgTriple; import lombok.extern.slf4j.Slf4j; /** - * @author lynn.bond@hotmail.com created on 2022/01/19 + * created on 2022/01/19 + * * @version 0.6.0 added batch scan on 2022/03/03 */ @Slf4j diff --git a/hg-store-client/src/main/java/org/apache/hugegraph/store/client/SequencedIterator.java b/hg-store-client/src/main/java/org/apache/hugegraph/store/client/SequencedIterator.java index f860eb148..f2725e268 100644 --- a/hg-store-client/src/main/java/org/apache/hugegraph/store/client/SequencedIterator.java +++ b/hg-store-client/src/main/java/org/apache/hugegraph/store/client/SequencedIterator.java @@ -31,8 +31,9 @@ import lombok.extern.slf4j.Slf4j; /** * Proxy iterator orderly, to switch next one will happen when the current one is empty. + *

+ * created on 2022/03/10 * - * @author lynn.bond@hotmail.com created on 2022/03/10 * @version 0.1.0 */ @Slf4j diff --git a/hg-store-client/src/main/java/org/apache/hugegraph/store/client/ShiftWorkIteratorProxy.java b/hg-store-client/src/main/java/org/apache/hugegraph/store/client/ShiftWorkIteratorProxy.java index e9bf06ec0..47e8195f9 100644 --- a/hg-store-client/src/main/java/org/apache/hugegraph/store/client/ShiftWorkIteratorProxy.java +++ b/hg-store-client/src/main/java/org/apache/hugegraph/store/client/ShiftWorkIteratorProxy.java @@ -29,7 +29,8 @@ import org.apache.hugegraph.store.HgKvPagingIterator; import lombok.extern.slf4j.Slf4j; /** - * @author lynn.bond@hotmail.com created on 2021/10/24 + * created on 2021/10/24 + * * @version 0.1.1 */ @Slf4j diff --git a/hg-store-client/src/main/java/org/apache/hugegraph/store/client/TopWorkIteratorProxy.java b/hg-store-client/src/main/java/org/apache/hugegraph/store/client/TopWorkIteratorProxy.java index 7e2267482..3c2872df9 100644 --- a/hg-store-client/src/main/java/org/apache/hugegraph/store/client/TopWorkIteratorProxy.java +++ b/hg-store-client/src/main/java/org/apache/hugegraph/store/client/TopWorkIteratorProxy.java @@ -26,7 +26,8 @@ import org.apache.hugegraph.store.HgKvEntry; import org.apache.hugegraph.store.HgKvIterator; /** - * @author lynn.bond@hotmail.com created on 2021/10/21 + * created on 2021/10/21 + * * @version 0.1.0 */ class TopWorkIteratorProxy implements HgKvIterator { diff --git a/hg-store-client/src/main/java/org/apache/hugegraph/store/client/grpc/AbstractGrpcClient.java b/hg-store-client/src/main/java/org/apache/hugegraph/store/client/grpc/AbstractGrpcClient.java index 76c3b5bbf..5a9df45a0 100644 --- a/hg-store-client/src/main/java/org/apache/hugegraph/store/client/grpc/AbstractGrpcClient.java +++ b/hg-store-client/src/main/java/org/apache/hugegraph/store/client/grpc/AbstractGrpcClient.java @@ -32,7 +32,6 @@ import io.grpc.stub.AbstractAsyncStub; import io.grpc.stub.AbstractBlockingStub; /** - * @author zhangyingjie * @date 2023/3/28 **/ public abstract class AbstractGrpcClient { diff --git a/hg-store-client/src/main/java/org/apache/hugegraph/store/client/grpc/GrpcKvEntryImpl.java b/hg-store-client/src/main/java/org/apache/hugegraph/store/client/grpc/GrpcKvEntryImpl.java index d2ef719b3..65bf97c2d 100644 --- a/hg-store-client/src/main/java/org/apache/hugegraph/store/client/grpc/GrpcKvEntryImpl.java +++ b/hg-store-client/src/main/java/org/apache/hugegraph/store/client/grpc/GrpcKvEntryImpl.java @@ -21,9 +21,7 @@ import java.util.Arrays; import org.apache.hugegraph.store.HgKvEntry; -/** - * @author lynn.bond@hotmail.com - */ + class GrpcKvEntryImpl implements HgKvEntry { private final byte[] key; private final byte[] value; diff --git a/hg-store-client/src/main/java/org/apache/hugegraph/store/client/grpc/GrpcKvIteratorImpl.java b/hg-store-client/src/main/java/org/apache/hugegraph/store/client/grpc/GrpcKvIteratorImpl.java index 23b743021..6d19c6b55 100644 --- a/hg-store-client/src/main/java/org/apache/hugegraph/store/client/grpc/GrpcKvIteratorImpl.java +++ b/hg-store-client/src/main/java/org/apache/hugegraph/store/client/grpc/GrpcKvIteratorImpl.java @@ -33,7 +33,8 @@ import org.apache.hugegraph.store.grpc.common.Kv; import lombok.extern.slf4j.Slf4j; /** - * @author lynn.bond@hotmail.com created on 2021/10/20 + * created on 2021/10/20 + * * @version 0.2.1 */ @Slf4j diff --git a/hg-store-client/src/main/java/org/apache/hugegraph/store/client/grpc/GrpcStoreNodeBuilder.java b/hg-store-client/src/main/java/org/apache/hugegraph/store/client/grpc/GrpcStoreNodeBuilder.java index f66452417..7f8bb2f6e 100644 --- a/hg-store-client/src/main/java/org/apache/hugegraph/store/client/grpc/GrpcStoreNodeBuilder.java +++ b/hg-store-client/src/main/java/org/apache/hugegraph/store/client/grpc/GrpcStoreNodeBuilder.java @@ -26,7 +26,7 @@ import org.apache.hugegraph.store.client.HgStoreNodeManager; import org.apache.hugegraph.store.client.util.HgAssert; /** - * @author lynn.bond@hotmail.com created on 2021/10/12 + * created on 2021/10/12 */ public class GrpcStoreNodeBuilder implements HgStoreNodeBuilder { diff --git a/hg-store-client/src/main/java/org/apache/hugegraph/store/client/grpc/GrpcStoreNodeImpl.java b/hg-store-client/src/main/java/org/apache/hugegraph/store/client/grpc/GrpcStoreNodeImpl.java index bb7d388ee..2c9df47a8 100644 --- a/hg-store-client/src/main/java/org/apache/hugegraph/store/client/grpc/GrpcStoreNodeImpl.java +++ b/hg-store-client/src/main/java/org/apache/hugegraph/store/client/grpc/GrpcStoreNodeImpl.java @@ -24,7 +24,7 @@ import org.apache.hugegraph.store.client.HgStoreNode; import org.apache.hugegraph.store.client.HgStoreNodeManager; /** - * @author lynn.bond@hotmail.com created on 2021/10/11 + * created on 2021/10/11 */ class GrpcStoreNodeImpl implements HgStoreNode { private final GrpcStoreSessionClient sessionClient; diff --git a/hg-store-client/src/main/java/org/apache/hugegraph/store/client/grpc/GrpcStoreNodeSessionImpl.java b/hg-store-client/src/main/java/org/apache/hugegraph/store/client/grpc/GrpcStoreNodeSessionImpl.java index acc1c83c6..a0eee04cb 100644 --- a/hg-store-client/src/main/java/org/apache/hugegraph/store/client/grpc/GrpcStoreNodeSessionImpl.java +++ b/hg-store-client/src/main/java/org/apache/hugegraph/store/client/grpc/GrpcStoreNodeSessionImpl.java @@ -53,7 +53,8 @@ import com.google.protobuf.UnsafeByteOperations; import lombok.extern.slf4j.Slf4j; /** - * @author lynn.bond@hotmail.com created on 2022/01/19 + * created on 2022/01/19 + * * @version 0.6.0 added batch get on 2022/04/06 */ @Slf4j diff --git a/hg-store-client/src/main/java/org/apache/hugegraph/store/client/grpc/GrpcStoreSessionClient.java b/hg-store-client/src/main/java/org/apache/hugegraph/store/client/grpc/GrpcStoreSessionClient.java index 108fba932..246c80eb8 100644 --- a/hg-store-client/src/main/java/org/apache/hugegraph/store/client/grpc/GrpcStoreSessionClient.java +++ b/hg-store-client/src/main/java/org/apache/hugegraph/store/client/grpc/GrpcStoreSessionClient.java @@ -41,7 +41,8 @@ import io.grpc.ManagedChannel; import lombok.extern.slf4j.Slf4j; /** - * @author lynn.bond@hotmail.com created on 2021/11/18 + * created on 2021/11/18 + * * @version 0.5.0 */ @Slf4j diff --git a/hg-store-client/src/main/java/org/apache/hugegraph/store/client/grpc/GrpcStoreStreamClient.java b/hg-store-client/src/main/java/org/apache/hugegraph/store/client/grpc/GrpcStoreStreamClient.java index 2a5bed53f..e7be4ac94 100644 --- a/hg-store-client/src/main/java/org/apache/hugegraph/store/client/grpc/GrpcStoreStreamClient.java +++ b/hg-store-client/src/main/java/org/apache/hugegraph/store/client/grpc/GrpcStoreStreamClient.java @@ -35,7 +35,8 @@ import io.grpc.stub.AbstractBlockingStub; import lombok.extern.slf4j.Slf4j; /** - * @author lynn.bond@hotmail.com created on 2021/10/19 + * created on 2021/10/19 + * * @version 1.1.1 added synchronized in getChannel. */ @Slf4j diff --git a/hg-store-client/src/main/java/org/apache/hugegraph/store/client/grpc/GrpcUtil.java b/hg-store-client/src/main/java/org/apache/hugegraph/store/client/grpc/GrpcUtil.java index 25b60c2ab..766aa4ae3 100644 --- a/hg-store-client/src/main/java/org/apache/hugegraph/store/client/grpc/GrpcUtil.java +++ b/hg-store-client/src/main/java/org/apache/hugegraph/store/client/grpc/GrpcUtil.java @@ -39,7 +39,7 @@ import io.grpc.Status; import io.grpc.StatusRuntimeException; /** - * @author lynn.bond@hotmail.com on 2022/1/19 + * 2022/1/19 */ final class GrpcUtil { diff --git a/hg-store-client/src/main/java/org/apache/hugegraph/store/client/grpc/KvBatchOneShotScanner.java b/hg-store-client/src/main/java/org/apache/hugegraph/store/client/grpc/KvBatchOneShotScanner.java index c069e631d..26b4e2019 100644 --- a/hg-store-client/src/main/java/org/apache/hugegraph/store/client/grpc/KvBatchOneShotScanner.java +++ b/hg-store-client/src/main/java/org/apache/hugegraph/store/client/grpc/KvBatchOneShotScanner.java @@ -37,7 +37,7 @@ import org.apache.hugegraph.store.grpc.stream.ScanStreamBatchReq; import lombok.extern.slf4j.Slf4j; /** - * @author lynn.bond@hotmail.com created on 2022/04/08 + * created on 2022/04/08 */ @Slf4j @NotThreadSafe diff --git a/hg-store-client/src/main/java/org/apache/hugegraph/store/client/grpc/KvBatchScanner.java b/hg-store-client/src/main/java/org/apache/hugegraph/store/client/grpc/KvBatchScanner.java index 692c4ef09..0a69d7cbc 100644 --- a/hg-store-client/src/main/java/org/apache/hugegraph/store/client/grpc/KvBatchScanner.java +++ b/hg-store-client/src/main/java/org/apache/hugegraph/store/client/grpc/KvBatchScanner.java @@ -48,8 +48,9 @@ import lombok.extern.slf4j.Slf4j; /** * 批量流式查询客户端实现类 + *

+ * created on 2022/07/23 * - * @author YanJinbing created on 2022/07/23 * @version 3.0.0 */ @Slf4j diff --git a/hg-store-client/src/main/java/org/apache/hugegraph/store/client/grpc/KvBatchScanner5.java b/hg-store-client/src/main/java/org/apache/hugegraph/store/client/grpc/KvBatchScanner5.java index 64f73395e..8ac48362a 100644 --- a/hg-store-client/src/main/java/org/apache/hugegraph/store/client/grpc/KvBatchScanner5.java +++ b/hg-store-client/src/main/java/org/apache/hugegraph/store/client/grpc/KvBatchScanner5.java @@ -44,7 +44,8 @@ import io.grpc.stub.StreamObserver; import lombok.extern.slf4j.Slf4j; /** - * @author lynn.bond@hotmail.com created on 2022/03/23 + * created on 2022/03/23 + * * @version 5.0.0 */ @Slf4j diff --git a/hg-store-client/src/main/java/org/apache/hugegraph/store/client/grpc/KvBatchUtil.java b/hg-store-client/src/main/java/org/apache/hugegraph/store/client/grpc/KvBatchUtil.java index 62f24ca12..20bcb5668 100644 --- a/hg-store-client/src/main/java/org/apache/hugegraph/store/client/grpc/KvBatchUtil.java +++ b/hg-store-client/src/main/java/org/apache/hugegraph/store/client/grpc/KvBatchUtil.java @@ -33,7 +33,7 @@ import com.google.protobuf.ByteString; import lombok.extern.slf4j.Slf4j; /** - * @author lynn.bond@hotmail.com created on 2022/04/23 + * created on 2022/04/23 */ @Slf4j @NotThreadSafe diff --git a/hg-store-client/src/main/java/org/apache/hugegraph/store/client/grpc/KvCloseableIterator.java b/hg-store-client/src/main/java/org/apache/hugegraph/store/client/grpc/KvCloseableIterator.java index 2eb9f9024..ac90b47ac 100644 --- a/hg-store-client/src/main/java/org/apache/hugegraph/store/client/grpc/KvCloseableIterator.java +++ b/hg-store-client/src/main/java/org/apache/hugegraph/store/client/grpc/KvCloseableIterator.java @@ -21,7 +21,7 @@ import java.io.Closeable; import java.util.Iterator; /** - * @author lynn.bond@hotmail.com on 2022/3/16 + * 2022/3/16 */ public interface KvCloseableIterator extends Iterator, Closeable { @Override diff --git a/hg-store-client/src/main/java/org/apache/hugegraph/store/client/grpc/KvListIterator.java b/hg-store-client/src/main/java/org/apache/hugegraph/store/client/grpc/KvListIterator.java index 943bd3924..cc33dfa63 100644 --- a/hg-store-client/src/main/java/org/apache/hugegraph/store/client/grpc/KvListIterator.java +++ b/hg-store-client/src/main/java/org/apache/hugegraph/store/client/grpc/KvListIterator.java @@ -21,7 +21,7 @@ import java.util.Iterator; import java.util.List; /** - * @author lynn.bond@hotmail.com on 2022/4/6 + * 2022/4/6 */ class KvListIterator implements KvCloseableIterator { diff --git a/hg-store-client/src/main/java/org/apache/hugegraph/store/client/grpc/KvOneShotScanner.java b/hg-store-client/src/main/java/org/apache/hugegraph/store/client/grpc/KvOneShotScanner.java index f5cc3bd0d..be4243a42 100644 --- a/hg-store-client/src/main/java/org/apache/hugegraph/store/client/grpc/KvOneShotScanner.java +++ b/hg-store-client/src/main/java/org/apache/hugegraph/store/client/grpc/KvOneShotScanner.java @@ -41,7 +41,7 @@ import com.google.protobuf.ByteString; import lombok.extern.slf4j.Slf4j; /** - * @author lynn.bond@hotmail.com created on 2021/12/1 + * created on 2021/12/1 */ @Slf4j @NotThreadSafe diff --git a/hg-store-client/src/main/java/org/apache/hugegraph/store/client/grpc/KvPageScanner.java b/hg-store-client/src/main/java/org/apache/hugegraph/store/client/grpc/KvPageScanner.java index 1a53672ed..c9e99d9b7 100644 --- a/hg-store-client/src/main/java/org/apache/hugegraph/store/client/grpc/KvPageScanner.java +++ b/hg-store-client/src/main/java/org/apache/hugegraph/store/client/grpc/KvPageScanner.java @@ -51,7 +51,8 @@ import io.grpc.stub.StreamObserver; import lombok.extern.slf4j.Slf4j; /** - * @author lynn.bond@hotmail.com created on 2021/10/21 + * created on 2021/10/21 + * * @version 0.6.1 lynn.bond@hotamil.com on 2022/04/05 */ @Slf4j diff --git a/hg-store-client/src/main/java/org/apache/hugegraph/store/client/grpc/NotifyingExecutor.java b/hg-store-client/src/main/java/org/apache/hugegraph/store/client/grpc/NotifyingExecutor.java index b5d4c8ebf..119bfc806 100644 --- a/hg-store-client/src/main/java/org/apache/hugegraph/store/client/grpc/NotifyingExecutor.java +++ b/hg-store-client/src/main/java/org/apache/hugegraph/store/client/grpc/NotifyingExecutor.java @@ -41,7 +41,8 @@ import com.google.protobuf.util.JsonFormat; import lombok.extern.slf4j.Slf4j; /** - * @author lynn.bond@hotmail.com on 2021/11/18 + * 2021/11/18 + * * @version 0.3.0 on 2022/01/27 */ @Slf4j diff --git a/hg-store-client/src/main/java/org/apache/hugegraph/store/client/grpc/ScanUtil.java b/hg-store-client/src/main/java/org/apache/hugegraph/store/client/grpc/ScanUtil.java index 42799ee08..4bed99dba 100644 --- a/hg-store-client/src/main/java/org/apache/hugegraph/store/client/grpc/ScanUtil.java +++ b/hg-store-client/src/main/java/org/apache/hugegraph/store/client/grpc/ScanUtil.java @@ -25,7 +25,6 @@ import org.apache.hugegraph.store.grpc.common.Header; import com.google.protobuf.ByteString; /** - * @author zhangyingjie * @date 2022/10/8 **/ public class ScanUtil { diff --git a/hg-store-client/src/main/java/org/apache/hugegraph/store/client/grpc/SeekAbleIterator.java b/hg-store-client/src/main/java/org/apache/hugegraph/store/client/grpc/SeekAbleIterator.java index 4f1a72f67..05beec0a0 100644 --- a/hg-store-client/src/main/java/org/apache/hugegraph/store/client/grpc/SeekAbleIterator.java +++ b/hg-store-client/src/main/java/org/apache/hugegraph/store/client/grpc/SeekAbleIterator.java @@ -25,7 +25,7 @@ import org.apache.hugegraph.store.HgSeekAble; import org.apache.hugegraph.store.client.util.HgAssert; /** - * @author lynn.bond@hotmail.com on 2022/3/11 + * 2022/3/11 */ class SeekAbleIterator implements Iterator, HgSeekAble { private final Iterator iterator; diff --git a/hg-store-client/src/main/java/org/apache/hugegraph/store/client/grpc/SwitchingExecutor.java b/hg-store-client/src/main/java/org/apache/hugegraph/store/client/grpc/SwitchingExecutor.java index 3e6423a33..7fecbe5bc 100644 --- a/hg-store-client/src/main/java/org/apache/hugegraph/store/client/grpc/SwitchingExecutor.java +++ b/hg-store-client/src/main/java/org/apache/hugegraph/store/client/grpc/SwitchingExecutor.java @@ -23,7 +23,7 @@ import java.util.function.Supplier; import javax.annotation.concurrent.ThreadSafe; /** - * @author lynn.bond@hotmail.com on 2021/12/1 + * 2021/12/1 */ @ThreadSafe final class SwitchingExecutor { diff --git a/hg-store-client/src/main/java/org/apache/hugegraph/store/client/type/HgNodeStatus.java b/hg-store-client/src/main/java/org/apache/hugegraph/store/client/type/HgNodeStatus.java index 61626dadb..8ff10bc03 100644 --- a/hg-store-client/src/main/java/org/apache/hugegraph/store/client/type/HgNodeStatus.java +++ b/hg-store-client/src/main/java/org/apache/hugegraph/store/client/type/HgNodeStatus.java @@ -18,7 +18,7 @@ package org.apache.hugegraph.store.client.type; /** - * @author lynn.bond@hotmail.com created on 2021/10/26 + * created on 2021/10/26 */ public enum HgNodeStatus { diff --git a/hg-store-client/src/main/java/org/apache/hugegraph/store/client/type/HgStoreClientException.java b/hg-store-client/src/main/java/org/apache/hugegraph/store/client/type/HgStoreClientException.java index 766068043..4b77dbe5d 100644 --- a/hg-store-client/src/main/java/org/apache/hugegraph/store/client/type/HgStoreClientException.java +++ b/hg-store-client/src/main/java/org/apache/hugegraph/store/client/type/HgStoreClientException.java @@ -18,7 +18,7 @@ package org.apache.hugegraph.store.client.type; /** - * @author lynn.bond@hotmail.com created on 2021/10/27 + * created on 2021/10/27 */ public class HgStoreClientException extends RuntimeException { diff --git a/hg-store-client/src/main/java/org/apache/hugegraph/store/client/util/ExecutorPool.java b/hg-store-client/src/main/java/org/apache/hugegraph/store/client/util/ExecutorPool.java index 2c67224c0..be28245f8 100644 --- a/hg-store-client/src/main/java/org/apache/hugegraph/store/client/util/ExecutorPool.java +++ b/hg-store-client/src/main/java/org/apache/hugegraph/store/client/util/ExecutorPool.java @@ -26,7 +26,7 @@ import java.util.concurrent.atomic.AtomicInteger; import lombok.extern.slf4j.Slf4j; /** - * @author lynn.bond@hotmail.com on 2021/11/22 + * 2021/11/22 */ @Slf4j public final class ExecutorPool { diff --git a/hg-store-client/src/main/java/org/apache/hugegraph/store/client/util/HgAssert.java b/hg-store-client/src/main/java/org/apache/hugegraph/store/client/util/HgAssert.java index e81bbda79..83e4c65bc 100644 --- a/hg-store-client/src/main/java/org/apache/hugegraph/store/client/util/HgAssert.java +++ b/hg-store-client/src/main/java/org/apache/hugegraph/store/client/util/HgAssert.java @@ -21,9 +21,7 @@ import java.util.Collection; import java.util.Map; import java.util.function.Supplier; -/** - * @author lynn.bond@hotmail.com - */ + public final class HgAssert { public static void isTrue(boolean expression, String message) { if (message == null) { diff --git a/hg-store-client/src/main/java/org/apache/hugegraph/store/client/util/HgBufferProxy.java b/hg-store-client/src/main/java/org/apache/hugegraph/store/client/util/HgBufferProxy.java index a50d93200..d9240d0e5 100644 --- a/hg-store-client/src/main/java/org/apache/hugegraph/store/client/util/HgBufferProxy.java +++ b/hg-store-client/src/main/java/org/apache/hugegraph/store/client/util/HgBufferProxy.java @@ -32,7 +32,8 @@ import org.apache.hugegraph.store.client.type.HgStoreClientException; import lombok.extern.slf4j.Slf4j; /** - * @author lynn.bond@hotmail.com on 2022/3/15 + * 2022/3/15 + * * @version 0.1.0 */ @Slf4j diff --git a/hg-store-client/src/main/java/org/apache/hugegraph/store/client/util/HgStoreClientConfig.java b/hg-store-client/src/main/java/org/apache/hugegraph/store/client/util/HgStoreClientConfig.java index dd9355b62..69818f90e 100644 --- a/hg-store-client/src/main/java/org/apache/hugegraph/store/client/util/HgStoreClientConfig.java +++ b/hg-store-client/src/main/java/org/apache/hugegraph/store/client/util/HgStoreClientConfig.java @@ -22,7 +22,7 @@ import java.util.PropertyResourceBundle; import lombok.extern.slf4j.Slf4j; /** - * @author lynn.bond@hotmail.com on 2021/11/29 + * 2021/11/29 */ @Slf4j public final class HgStoreClientConfig { diff --git a/hg-store-client/src/main/java/org/apache/hugegraph/store/client/util/HgStoreClientConst.java b/hg-store-client/src/main/java/org/apache/hugegraph/store/client/util/HgStoreClientConst.java index 53892de60..47955f597 100644 --- a/hg-store-client/src/main/java/org/apache/hugegraph/store/client/util/HgStoreClientConst.java +++ b/hg-store-client/src/main/java/org/apache/hugegraph/store/client/util/HgStoreClientConst.java @@ -23,9 +23,7 @@ import java.util.List; import org.apache.hugegraph.store.HgKvStore; import org.apache.hugegraph.store.HgOwnerKey; -/** - * @author lynn.bond@hotmail.com - */ + public final class HgStoreClientConst { public final static String DEFAULT_NODE_CLUSTER_ID = "default-node-cluster"; diff --git a/hg-store-client/src/main/java/org/apache/hugegraph/store/client/util/HgStoreClientUtil.java b/hg-store-client/src/main/java/org/apache/hugegraph/store/client/util/HgStoreClientUtil.java index 83b326c25..71001d5bc 100644 --- a/hg-store-client/src/main/java/org/apache/hugegraph/store/client/util/HgStoreClientUtil.java +++ b/hg-store-client/src/main/java/org/apache/hugegraph/store/client/util/HgStoreClientUtil.java @@ -29,7 +29,7 @@ import org.apache.hugegraph.store.client.type.HgStoreClientException; import lombok.extern.slf4j.Slf4j; /** - * @author lynn.bond@hotmail.com created on 2021/10/14 + * created on 2021/10/14 */ @Slf4j public final class HgStoreClientUtil { diff --git a/hg-store-client/src/main/java/org/apache/hugegraph/store/client/util/HgUuid.java b/hg-store-client/src/main/java/org/apache/hugegraph/store/client/util/HgUuid.java index 79c35670d..f92e688ee 100644 --- a/hg-store-client/src/main/java/org/apache/hugegraph/store/client/util/HgUuid.java +++ b/hg-store-client/src/main/java/org/apache/hugegraph/store/client/util/HgUuid.java @@ -20,9 +20,7 @@ package org.apache.hugegraph.store.client.util; import java.nio.ByteBuffer; import java.util.UUID; -/** - * @author lynn.bond@hotmail.com - */ + public final class HgUuid { private static String encode(UUID uuid) { diff --git a/hg-store-client/src/main/java/org/apache/hugegraph/store/client/util/MetricX.java b/hg-store-client/src/main/java/org/apache/hugegraph/store/client/util/MetricX.java index ce9c7dbdd..a50a7110b 100644 --- a/hg-store-client/src/main/java/org/apache/hugegraph/store/client/util/MetricX.java +++ b/hg-store-client/src/main/java/org/apache/hugegraph/store/client/util/MetricX.java @@ -20,7 +20,7 @@ package org.apache.hugegraph.store.client.util; import java.util.concurrent.atomic.AtomicLong; /** - * @author lynn.bond@hotmail.com on 2022/1/29 + * 2022/1/29 */ public class MetricX { public static AtomicLong iteratorSum = new AtomicLong(); diff --git a/hg-store-client/src/test/java/org/apache/hugegraph/store/client/HgStoreNodeSessionTest.java b/hg-store-client/src/test/java/org/apache/hugegraph/store/client/HgStoreNodeSessionTest.java index 736ccb8a7..2edbec574 100644 --- a/hg-store-client/src/test/java/org/apache/hugegraph/store/client/HgStoreNodeSessionTest.java +++ b/hg-store-client/src/test/java/org/apache/hugegraph/store/client/HgStoreNodeSessionTest.java @@ -26,7 +26,7 @@ import org.apache.hugegraph.store.HgStoreSession; import org.junit.Assert; /** - * @author lynn.bond@hotmail.com created on 2021/10/12 + * created on 2021/10/12 */ public class HgStoreNodeSessionTest { private static final HgStoreNodeManager nodeManager = HgStoreNodeManager.getInstance(); diff --git a/hg-store-client/src/test/java/org/apache/hugegraph/store/client/HgStoreNodeStreamTest.java b/hg-store-client/src/test/java/org/apache/hugegraph/store/client/HgStoreNodeStreamTest.java index f83357790..25fc59282 100644 --- a/hg-store-client/src/test/java/org/apache/hugegraph/store/client/HgStoreNodeStreamTest.java +++ b/hg-store-client/src/test/java/org/apache/hugegraph/store/client/HgStoreNodeStreamTest.java @@ -30,7 +30,7 @@ import org.apache.hugegraph.store.HgStoreSession; import org.junit.Assert; /** - * @author lynn.bond@hotmail.com created on 2021/10/12 + * created on 2021/10/12 */ public class HgStoreNodeStreamTest { private static final HgStoreNodeManager nodeManager = HgStoreNodeManager.getInstance(); diff --git a/hg-store-client/src/test/java/org/apache/hugegraph/store/util/HgStoreTestUtil.java b/hg-store-client/src/test/java/org/apache/hugegraph/store/util/HgStoreTestUtil.java index c7b9e7abc..d935dc369 100644 --- a/hg-store-client/src/test/java/org/apache/hugegraph/store/util/HgStoreTestUtil.java +++ b/hg-store-client/src/test/java/org/apache/hugegraph/store/util/HgStoreTestUtil.java @@ -43,7 +43,7 @@ import org.apache.hugegraph.store.client.util.MetricX; import lombok.extern.slf4j.Slf4j; /** - * @author lynn.bond@hotmail.com created on 2021/10/12 + * created on 2021/10/12 */ @Slf4j public class HgStoreTestUtil { diff --git a/hg-store-common/src/main/java/org/apache/hugegraph/store/term/HgPair.java b/hg-store-common/src/main/java/org/apache/hugegraph/store/term/HgPair.java index 61cf97013..4a5616412 100644 --- a/hg-store-common/src/main/java/org/apache/hugegraph/store/term/HgPair.java +++ b/hg-store-common/src/main/java/org/apache/hugegraph/store/term/HgPair.java @@ -22,8 +22,8 @@ import java.util.Objects; /** * Copy from javafx.util:Pair - * - * @author lynn.bond@hotmail.com created on 2021/10/15 + *

+ * created on 2021/10/15 */ public class HgPair implements Serializable { diff --git a/hg-store-common/src/main/java/org/apache/hugegraph/store/term/HgTriple.java b/hg-store-common/src/main/java/org/apache/hugegraph/store/term/HgTriple.java index 3fd6de0cb..04cd05359 100644 --- a/hg-store-common/src/main/java/org/apache/hugegraph/store/term/HgTriple.java +++ b/hg-store-common/src/main/java/org/apache/hugegraph/store/term/HgTriple.java @@ -20,7 +20,7 @@ package org.apache.hugegraph.store.term; import java.util.Objects; /** - * @author lynn.bond@hotmail.com created on 2021/10/19 + * created on 2021/10/19 */ public class HgTriple { private final X x; diff --git a/hg-store-core/src/main/java/org/apache/hugegraph/store/HgStoreEngine.java b/hg-store-core/src/main/java/org/apache/hugegraph/store/HgStoreEngine.java index a986011fa..e8755d532 100644 --- a/hg-store-core/src/main/java/org/apache/hugegraph/store/HgStoreEngine.java +++ b/hg-store-core/src/main/java/org/apache/hugegraph/store/HgStoreEngine.java @@ -64,8 +64,6 @@ import lombok.extern.slf4j.Slf4j; /** * The core class of the storage engine, initializing PD client and raft client - * - * @author YanJinbing */ @Slf4j public class HgStoreEngine implements Lifecycle, HgStoreStateListener { diff --git a/hg-store-core/src/main/java/org/apache/hugegraph/store/business/AbstractSelectIterator.java b/hg-store-core/src/main/java/org/apache/hugegraph/store/business/AbstractSelectIterator.java index 6f4ce8b9d..da9bb5f8e 100644 --- a/hg-store-core/src/main/java/org/apache/hugegraph/store/business/AbstractSelectIterator.java +++ b/hg-store-core/src/main/java/org/apache/hugegraph/store/business/AbstractSelectIterator.java @@ -29,7 +29,6 @@ import org.apache.tinkerpop.gremlin.structure.Edge; import lombok.extern.slf4j.Slf4j; /** - * @author zhangyingjie * @date 2022/10/26 **/ @Slf4j diff --git a/hg-store-core/src/main/java/org/apache/hugegraph/store/business/BusinessHandler.java b/hg-store-core/src/main/java/org/apache/hugegraph/store/business/BusinessHandler.java index b73e63bb6..2ef0c8c2e 100644 --- a/hg-store-core/src/main/java/org/apache/hugegraph/store/business/BusinessHandler.java +++ b/hg-store-core/src/main/java/org/apache/hugegraph/store/business/BusinessHandler.java @@ -44,7 +44,6 @@ import org.slf4j.LoggerFactory; * @projectName: hugegraph-store * @package: org.apache.hugegraph.store.business * @className: HgBusinessHandler - * @author: tyzer * @description: * @date: 2021/10/19 19:07 * @version: 1.0 diff --git a/hg-store-core/src/main/java/org/apache/hugegraph/store/business/BusinessHandlerImpl.java b/hg-store-core/src/main/java/org/apache/hugegraph/store/business/BusinessHandlerImpl.java index 8f7cf2ea1..8172171e5 100644 --- a/hg-store-core/src/main/java/org/apache/hugegraph/store/business/BusinessHandlerImpl.java +++ b/hg-store-core/src/main/java/org/apache/hugegraph/store/business/BusinessHandlerImpl.java @@ -72,7 +72,6 @@ import lombok.extern.slf4j.Slf4j; * @projectName: hugegraph-store * @package: org.apache.hugegraph.store.business * @className: HgBusinessImpl - * @author: tyzer * @description: TODO * @date: 2021/10/19 19:17 * @version: 1.0 diff --git a/hg-store-core/src/main/java/org/apache/hugegraph/store/business/GraphStoreIterator.java b/hg-store-core/src/main/java/org/apache/hugegraph/store/business/GraphStoreIterator.java index 3c82c142a..7d692899f 100644 --- a/hg-store-core/src/main/java/org/apache/hugegraph/store/business/GraphStoreIterator.java +++ b/hg-store-core/src/main/java/org/apache/hugegraph/store/business/GraphStoreIterator.java @@ -62,7 +62,6 @@ import com.google.protobuf.Descriptors; import lombok.extern.slf4j.Slf4j; /** - * @author zhangyingjie * @date 2022/10/26 **/ @Slf4j diff --git a/hg-store-core/src/main/java/org/apache/hugegraph/store/business/MultiPartitionIterator.java b/hg-store-core/src/main/java/org/apache/hugegraph/store/business/MultiPartitionIterator.java index 214e2e794..a573df370 100644 --- a/hg-store-core/src/main/java/org/apache/hugegraph/store/business/MultiPartitionIterator.java +++ b/hg-store-core/src/main/java/org/apache/hugegraph/store/business/MultiPartitionIterator.java @@ -30,7 +30,8 @@ import org.apache.hugegraph.rocksdb.access.ScanIterator; import lombok.extern.slf4j.Slf4j; /** - * @author lynn.bond@hotmail.com created on 2021/11/2 + * created on 2021/11/2 + * * @version 1.1.0 implements position method to pass partition-id on 2022/03/10 */ @Slf4j diff --git a/hg-store-core/src/main/java/org/apache/hugegraph/store/business/SelectIterator.java b/hg-store-core/src/main/java/org/apache/hugegraph/store/business/SelectIterator.java index 284d5b02c..56425b7fd 100644 --- a/hg-store-core/src/main/java/org/apache/hugegraph/store/business/SelectIterator.java +++ b/hg-store-core/src/main/java/org/apache/hugegraph/store/business/SelectIterator.java @@ -29,7 +29,6 @@ import org.apache.hugegraph.type.define.DataType; import org.apache.hugegraph.type.define.SerialEnum; /** - * @author zhangyingjie * @date 2022/9/23 **/ public class SelectIterator implements ScanIterator { diff --git a/hg-store-core/src/main/java/org/apache/hugegraph/store/meta/Partition.java b/hg-store-core/src/main/java/org/apache/hugegraph/store/meta/Partition.java index 475c55ece..8aca2b021 100644 --- a/hg-store-core/src/main/java/org/apache/hugegraph/store/meta/Partition.java +++ b/hg-store-core/src/main/java/org/apache/hugegraph/store/meta/Partition.java @@ -27,7 +27,6 @@ import lombok.Data; * @projectName: hugegraph-store * @package: org.apache.hugegraph.store.partitions * @className: Partition - * @author: tyzer * @description: TODO * @date: 2021/10/19 18:16 * @version: 1.0 diff --git a/hg-store-core/src/main/java/org/apache/hugegraph/store/meta/PartitionRole.java b/hg-store-core/src/main/java/org/apache/hugegraph/store/meta/PartitionRole.java index a3f88b775..b001b5536 100644 --- a/hg-store-core/src/main/java/org/apache/hugegraph/store/meta/PartitionRole.java +++ b/hg-store-core/src/main/java/org/apache/hugegraph/store/meta/PartitionRole.java @@ -23,7 +23,6 @@ import org.apache.hugegraph.pd.grpc.Metapb; * @projectName: hugegraph-store * @package: org.apache.hugegraph.store.partitions * @className: PartitionRole - * @author: tyzer * @description: TODO * @date: 2021/10/19 18:18 * @version: 1.0 diff --git a/hg-store-core/src/main/java/org/apache/hugegraph/store/meta/Store.java b/hg-store-core/src/main/java/org/apache/hugegraph/store/meta/Store.java index 5b20ed77b..23df46796 100644 --- a/hg-store-core/src/main/java/org/apache/hugegraph/store/meta/Store.java +++ b/hg-store-core/src/main/java/org/apache/hugegraph/store/meta/Store.java @@ -29,7 +29,6 @@ import lombok.Data; * @projectName: hugegraph-store * @package: org.apache.hugegraph.store.core * @className: HgStoreNode - * @author: tyzer * @description: TODO * @date: 2021/10/19 19:44 * @version: 1.0 diff --git a/hg-store-core/src/main/java/org/apache/hugegraph/store/options/RaftRocksdbOptions.java b/hg-store-core/src/main/java/org/apache/hugegraph/store/options/RaftRocksdbOptions.java index bc092343e..1db3260ab 100644 --- a/hg-store-core/src/main/java/org/apache/hugegraph/store/options/RaftRocksdbOptions.java +++ b/hg-store-core/src/main/java/org/apache/hugegraph/store/options/RaftRocksdbOptions.java @@ -55,24 +55,17 @@ public class RaftRocksdbOptions { private static void registerRaftRocksdbConfig(HugeConfig options) { Cache blockCache = new LRUCache(SizeUnit.GB); - BlockBasedTableConfig tableConfig = new BlockBasedTableConfig() // - .setIndexType( - IndexType.kTwoLevelIndexSearch) // - .setPartitionFilters( - true) // - .setMetadataBlockSize( - 8 * SizeUnit.KB) // - .setCacheIndexAndFilterBlocks( - options.get( - RocksDBOptions.PUT_FILTER_AND_INDEX_IN_CACHE)) // - .setCacheIndexAndFilterBlocksWithHighPriority( - true) // - .setPinL0FilterAndIndexBlocksInCache( - options.get( - RocksDBOptions.PIN_L0_FILTER_AND_INDEX_IN_CACHE)) // - .setBlockSize( - 4 * SizeUnit.KB)// - .setBlockCache(blockCache); + BlockBasedTableConfig tableConfig = new BlockBasedTableConfig() + .setIndexType(IndexType.kTwoLevelIndexSearch) + .setPartitionFilters(true) // + .setMetadataBlockSize(8 * SizeUnit.KB) // + .setCacheIndexAndFilterBlocks( + options.get(RocksDBOptions.PUT_FILTER_AND_INDEX_IN_CACHE)) + .setCacheIndexAndFilterBlocksWithHighPriority(true) + .setPinL0FilterAndIndexBlocksInCache( + options.get(RocksDBOptions.PIN_L0_FILTER_AND_INDEX_IN_CACHE)) + .setBlockSize(4 * SizeUnit.KB) + .setBlockCache(blockCache); StorageOptionsFactory.registerRocksDBTableFormatConfig(RocksDBLogStorage.class, tableConfig); diff --git a/hg-store-core/src/main/java/org/apache/hugegraph/store/pd/FakePdServiceProvider.java b/hg-store-core/src/main/java/org/apache/hugegraph/store/pd/FakePdServiceProvider.java index 2595bbab3..43ccc6e39 100644 --- a/hg-store-core/src/main/java/org/apache/hugegraph/store/pd/FakePdServiceProvider.java +++ b/hg-store-core/src/main/java/org/apache/hugegraph/store/pd/FakePdServiceProvider.java @@ -40,8 +40,6 @@ import lombok.extern.slf4j.Slf4j; /** * 内置PD服务，用于单机部署或开发调试 - * - * @author liyan75 */ @Slf4j public class FakePdServiceProvider implements PdProvider { diff --git a/hg-store-core/src/main/java/org/apache/hugegraph/store/raft/HgStoreStateMachine.java b/hg-store-core/src/main/java/org/apache/hugegraph/store/raft/HgStoreStateMachine.java index 169707d88..3ba1fe3b1 100644 --- a/hg-store-core/src/main/java/org/apache/hugegraph/store/raft/HgStoreStateMachine.java +++ b/hg-store-core/src/main/java/org/apache/hugegraph/store/raft/HgStoreStateMachine.java @@ -42,8 +42,6 @@ import com.alipay.sofa.jraft.util.Utils; /** * Raft 状态机 - * - * @author Yanjinbing */ public class HgStoreStateMachine extends StateMachineAdapter { diff --git a/hg-store-core/src/main/java/org/apache/hugegraph/store/util/Asserts.java b/hg-store-core/src/main/java/org/apache/hugegraph/store/util/Asserts.java index 51b0d4b7a..816adc8e4 100644 --- a/hg-store-core/src/main/java/org/apache/hugegraph/store/util/Asserts.java +++ b/hg-store-core/src/main/java/org/apache/hugegraph/store/util/Asserts.java @@ -17,9 +17,7 @@ package org.apache.hugegraph.store.util; -/** - * @author lynn.bond@hotmail.com - */ + public final class Asserts { public static void isTrue(boolean expression, String message) { if (message == null) { diff --git a/hg-store-core/src/main/java/org/apache/hugegraph/store/util/HgStoreConst.java b/hg-store-core/src/main/java/org/apache/hugegraph/store/util/HgStoreConst.java index 3e1dcb824..af285e3e0 100644 --- a/hg-store-core/src/main/java/org/apache/hugegraph/store/util/HgStoreConst.java +++ b/hg-store-core/src/main/java/org/apache/hugegraph/store/util/HgStoreConst.java @@ -21,7 +21,7 @@ import java.util.Collections; import java.util.List; /** - * @author lynn.bond@hotmail.com created on 2021/10/22 + * created on 2021/10/22 */ public final class HgStoreConst { public final static byte[] EMPTY_BYTES = new byte[0]; diff --git a/hg-store-core/src/main/java/org/apache/hugegraph/store/util/HgStoreException.java b/hg-store-core/src/main/java/org/apache/hugegraph/store/util/HgStoreException.java index b4bf0aa99..8ebe3053a 100644 --- a/hg-store-core/src/main/java/org/apache/hugegraph/store/util/HgStoreException.java +++ b/hg-store-core/src/main/java/org/apache/hugegraph/store/util/HgStoreException.java @@ -21,7 +21,6 @@ package org.apache.hugegraph.store.util; * @projectName: hugegraph-store * @package: org.apache.hugegraph.store * @className: HgCoreServiceException - * @author: tyzer * @description: TODO * @date: 2021/10/22 9:44 * @version: 1.0 diff --git a/hg-store-core/src/main/java/org/apache/hugegraph/store/util/Lifecycle.java b/hg-store-core/src/main/java/org/apache/hugegraph/store/util/Lifecycle.java index ec6a9d078..e7b646abf 100644 --- a/hg-store-core/src/main/java/org/apache/hugegraph/store/util/Lifecycle.java +++ b/hg-store-core/src/main/java/org/apache/hugegraph/store/util/Lifecycle.java @@ -17,9 +17,6 @@ package org.apache.hugegraph.store.util; -/** - * @author YanJinbing - */ public interface Lifecycle { /** diff --git a/hg-store-core/src/main/java/org/apache/hugegraph/store/util/ManualResetEvent.java b/hg-store-core/src/main/java/org/apache/hugegraph/store/util/ManualResetEvent.java index 4fb95d17d..1d19dcc71 100644 --- a/hg-store-core/src/main/java/org/apache/hugegraph/store/util/ManualResetEvent.java +++ b/hg-store-core/src/main/java/org/apache/hugegraph/store/util/ManualResetEvent.java @@ -21,7 +21,6 @@ import java.util.concurrent.CountDownLatch; import java.util.concurrent.TimeUnit; /** - * @author dominicwilliams * Updated by RoshanF on 12/28/2015. */ public class ManualResetEvent { diff --git a/hg-store-core/src/main/java/org/apache/hugegraph/store/util/UnsafeUtf8Util.java b/hg-store-core/src/main/java/org/apache/hugegraph/store/util/UnsafeUtf8Util.java index 6d6e23308..c2c8868a6 100644 --- a/hg-store-core/src/main/java/org/apache/hugegraph/store/util/UnsafeUtf8Util.java +++ b/hg-store-core/src/main/java/org/apache/hugegraph/store/util/UnsafeUtf8Util.java @@ -31,7 +31,6 @@ import java.util.Arrays; * @projectName: hugegraph-store * @package: org.apache.hugegraph.store.util * @className: UnsafeUtf8Util - * @author: jraft * @description: * @date: 2021/10/21 11:48 * @version: 1.0 diff --git a/hg-store-core/src/main/java/org/apache/hugegraph/store/util/UnsafeUtil.java b/hg-store-core/src/main/java/org/apache/hugegraph/store/util/UnsafeUtil.java index 8a7e26964..fa9b034f1 100644 --- a/hg-store-core/src/main/java/org/apache/hugegraph/store/util/UnsafeUtil.java +++ b/hg-store-core/src/main/java/org/apache/hugegraph/store/util/UnsafeUtil.java @@ -25,7 +25,6 @@ import lombok.extern.slf4j.Slf4j; * @projectName: hugegraph-store * @package: org.apache.hugegraph.store.util * @className: - * @author: jraft * @description: * @date: 2021/10/21 11:44 * @version: 1.0 diff --git a/hg-store-node/src/main/java/org/apache/hugegraph/store/node/AppConfig.java b/hg-store-node/src/main/java/org/apache/hugegraph/store/node/AppConfig.java index efbfe2e1a..473a8a3b3 100644 --- a/hg-store-node/src/main/java/org/apache/hugegraph/store/node/AppConfig.java +++ b/hg-store-node/src/main/java/org/apache/hugegraph/store/node/AppConfig.java @@ -30,9 +30,6 @@ import org.springframework.stereotype.Component; import lombok.Data; -/** - * @author lynn.bond@hotmail.com - */ @Data @Component public class AppConfig { diff --git a/hg-store-node/src/main/java/org/apache/hugegraph/store/node/AppShutdownHook.java b/hg-store-node/src/main/java/org/apache/hugegraph/store/node/AppShutdownHook.java index d31fba3b9..5a08b7964 100644 --- a/hg-store-node/src/main/java/org/apache/hugegraph/store/node/AppShutdownHook.java +++ b/hg-store-node/src/main/java/org/apache/hugegraph/store/node/AppShutdownHook.java @@ -20,7 +20,7 @@ package org.apache.hugegraph.store.node; import org.apache.hugegraph.rocksdb.access.RocksDBFactory; /** - * @author lynn.bond@hotmail.com copy from web + * copy from web */ public class AppShutdownHook extends Thread { diff --git a/hg-store-node/src/main/java/org/apache/hugegraph/store/node/controller/HgStoreMetricsController.java b/hg-store-node/src/main/java/org/apache/hugegraph/store/node/controller/HgStoreMetricsController.java index f455ea228..99ff83954 100644 --- a/hg-store-node/src/main/java/org/apache/hugegraph/store/node/controller/HgStoreMetricsController.java +++ b/hg-store-node/src/main/java/org/apache/hugegraph/store/node/controller/HgStoreMetricsController.java @@ -32,7 +32,7 @@ import org.springframework.web.bind.annotation.RestController; import com.alipay.sofa.jraft.core.NodeMetrics; /** - * @author lynn.bond@hotmail.com on 2021/11/23 + * 2021/11/23 */ @RestController @RequestMapping(value = "/metrics", method = RequestMethod.GET) diff --git a/hg-store-node/src/main/java/org/apache/hugegraph/store/node/controller/HgStoreStatusController.java b/hg-store-node/src/main/java/org/apache/hugegraph/store/node/controller/HgStoreStatusController.java index 2af814a23..bc2a8483c 100644 --- a/hg-store-node/src/main/java/org/apache/hugegraph/store/node/controller/HgStoreStatusController.java +++ b/hg-store-node/src/main/java/org/apache/hugegraph/store/node/controller/HgStoreStatusController.java @@ -35,7 +35,7 @@ import org.springframework.web.bind.annotation.RestController; import com.google.protobuf.util.JsonFormat; /** - * @author lynn.bond@hotmail.com created on 2021/11/1 + * created on 2021/11/1 */ @RestController public class HgStoreStatusController { diff --git a/hg-store-node/src/main/java/org/apache/hugegraph/store/node/grpc/BatchScanIterator.java b/hg-store-node/src/main/java/org/apache/hugegraph/store/node/grpc/BatchScanIterator.java index c2a71c83d..dbbb7a670 100644 --- a/hg-store-node/src/main/java/org/apache/hugegraph/store/node/grpc/BatchScanIterator.java +++ b/hg-store-node/src/main/java/org/apache/hugegraph/store/node/grpc/BatchScanIterator.java @@ -29,7 +29,8 @@ import org.apache.hugegraph.store.node.util.HgAssert; import org.apache.hugegraph.store.node.util.HgStoreConst; /** - * @author lynn.bond@hotmail.com on 2022/2/28 + * 2022/2/28 + * * @version 0.3.0 added limit support */ @NotThreadSafe diff --git a/hg-store-node/src/main/java/org/apache/hugegraph/store/node/grpc/EmptyIterator.java b/hg-store-node/src/main/java/org/apache/hugegraph/store/node/grpc/EmptyIterator.java index a66ab251d..6df461fc0 100644 --- a/hg-store-node/src/main/java/org/apache/hugegraph/store/node/grpc/EmptyIterator.java +++ b/hg-store-node/src/main/java/org/apache/hugegraph/store/node/grpc/EmptyIterator.java @@ -20,7 +20,7 @@ package org.apache.hugegraph.store.node.grpc; import org.apache.hugegraph.rocksdb.access.ScanIterator; /** - * @author lynn.bond@hotmail.com on 2021/11/29 + * 2021/11/29 */ final class EmptyIterator implements ScanIterator { diff --git a/hg-store-node/src/main/java/org/apache/hugegraph/store/node/grpc/FusingScanIterator.java b/hg-store-node/src/main/java/org/apache/hugegraph/store/node/grpc/FusingScanIterator.java index 78f14110e..0e31a9c2c 100644 --- a/hg-store-node/src/main/java/org/apache/hugegraph/store/node/grpc/FusingScanIterator.java +++ b/hg-store-node/src/main/java/org/apache/hugegraph/store/node/grpc/FusingScanIterator.java @@ -25,8 +25,8 @@ import org.apache.hugegraph.rocksdb.access.ScanIterator; /** * This is a wrapper of the ScanIterator that provides a mechanism * to set a threshold value in order to abort the iterating operation. - * - * @author lynn.bond@hotmail.com on 2023/2/8 + *

+ * 2023/2/8 */ final class FusingScanIterator implements ScanIterator { public static final byte[] EMPTY_BYTES = new byte[0]; diff --git a/hg-store-node/src/main/java/org/apache/hugegraph/store/node/grpc/GRpcServerConfig.java b/hg-store-node/src/main/java/org/apache/hugegraph/store/node/grpc/GRpcServerConfig.java index 4519b3450..68b1809f7 100644 --- a/hg-store-node/src/main/java/org/apache/hugegraph/store/node/grpc/GRpcServerConfig.java +++ b/hg-store-node/src/main/java/org/apache/hugegraph/store/node/grpc/GRpcServerConfig.java @@ -26,7 +26,7 @@ import org.springframework.stereotype.Component; import io.grpc.ServerBuilder; /** - * @author lynn.bond@hotmail.com on 2022/3/4 + * 2022/3/4 */ @Component public class GRpcServerConfig extends GRpcServerBuilderConfigurer { diff --git a/hg-store-node/src/main/java/org/apache/hugegraph/store/node/grpc/GrpcClosure.java b/hg-store-node/src/main/java/org/apache/hugegraph/store/node/grpc/GrpcClosure.java index d4ba9d882..14f39b3f5 100644 --- a/hg-store-node/src/main/java/org/apache/hugegraph/store/node/grpc/GrpcClosure.java +++ b/hg-store-node/src/main/java/org/apache/hugegraph/store/node/grpc/GrpcClosure.java @@ -27,7 +27,7 @@ import org.apache.hugegraph.store.raft.RaftClosure; import io.grpc.stub.StreamObserver; /** - * @author lynn.bond@hotmail.com on 2022/1/27 + * 2022/1/27 */ abstract class GrpcClosure implements RaftClosure { diff --git a/hg-store-node/src/main/java/org/apache/hugegraph/store/node/grpc/HgStoreNodeState.java b/hg-store-node/src/main/java/org/apache/hugegraph/store/node/grpc/HgStoreNodeState.java index 7f5d1faac..823ee4f94 100644 --- a/hg-store-node/src/main/java/org/apache/hugegraph/store/node/grpc/HgStoreNodeState.java +++ b/hg-store-node/src/main/java/org/apache/hugegraph/store/node/grpc/HgStoreNodeState.java @@ -22,7 +22,7 @@ import javax.annotation.concurrent.ThreadSafe; import org.apache.hugegraph.store.grpc.state.NodeStateType; /** - * @author lynn.bond@hotmail.com created on 2021/11/3 + * created on 2021/11/3 */ @ThreadSafe public final class HgStoreNodeState { diff --git a/hg-store-node/src/main/java/org/apache/hugegraph/store/node/grpc/HgStoreStateService.java b/hg-store-node/src/main/java/org/apache/hugegraph/store/node/grpc/HgStoreStateService.java index 975164b1b..760748c11 100644 --- a/hg-store-node/src/main/java/org/apache/hugegraph/store/node/grpc/HgStoreStateService.java +++ b/hg-store-node/src/main/java/org/apache/hugegraph/store/node/grpc/HgStoreStateService.java @@ -31,7 +31,7 @@ import io.grpc.stub.StreamObserver; import lombok.extern.slf4j.Slf4j; /** - * @author lynn.bond@hotmail.com created on 2021/11/3 + * created on 2021/11/3 */ @Slf4j @GRpcService diff --git a/hg-store-node/src/main/java/org/apache/hugegraph/store/node/grpc/HgStoreStateSubject.java b/hg-store-node/src/main/java/org/apache/hugegraph/store/node/grpc/HgStoreStateSubject.java index 26da5d208..76fe769ed 100644 --- a/hg-store-node/src/main/java/org/apache/hugegraph/store/node/grpc/HgStoreStateSubject.java +++ b/hg-store-node/src/main/java/org/apache/hugegraph/store/node/grpc/HgStoreStateSubject.java @@ -29,7 +29,7 @@ import io.grpc.stub.StreamObserver; import lombok.extern.slf4j.Slf4j; /** - * @author lynn.bond@hotmail.com created on 2021/11/3 + * created on 2021/11/3 */ @Slf4j public final class HgStoreStateSubject { diff --git a/hg-store-node/src/main/java/org/apache/hugegraph/store/node/grpc/HgStoreStreamImpl.java b/hg-store-node/src/main/java/org/apache/hugegraph/store/node/grpc/HgStoreStreamImpl.java index 28125dd57..3b688eb04 100644 --- a/hg-store-node/src/main/java/org/apache/hugegraph/store/node/grpc/HgStoreStreamImpl.java +++ b/hg-store-node/src/main/java/org/apache/hugegraph/store/node/grpc/HgStoreStreamImpl.java @@ -35,7 +35,7 @@ import io.grpc.stub.StreamObserver; import lombok.extern.slf4j.Slf4j; /** - * @author lynn.bond@hotmail.com created on 2021/10/19 + * created on 2021/10/19 */ @Slf4j @GRpcService diff --git a/hg-store-node/src/main/java/org/apache/hugegraph/store/node/grpc/HgStoreWrapperEx.java b/hg-store-node/src/main/java/org/apache/hugegraph/store/node/grpc/HgStoreWrapperEx.java index f08abffd4..e5f6141c2 100644 --- a/hg-store-node/src/main/java/org/apache/hugegraph/store/node/grpc/HgStoreWrapperEx.java +++ b/hg-store-node/src/main/java/org/apache/hugegraph/store/node/grpc/HgStoreWrapperEx.java @@ -35,7 +35,6 @@ import lombok.extern.slf4j.Slf4j; * @projectName: hugegraph-store * @package: org.apache.hugegraph.store.grpc.boot.service * @className: HgStoreWrapperEx - * @author: tyzer * @description: TODO * @date: 2021/10/25 18:35 * @version: 1.0 diff --git a/hg-store-node/src/main/java/org/apache/hugegraph/store/node/grpc/QueryCondition.java b/hg-store-node/src/main/java/org/apache/hugegraph/store/node/grpc/QueryCondition.java index 3d147469c..edc6e3602 100644 --- a/hg-store-node/src/main/java/org/apache/hugegraph/store/node/grpc/QueryCondition.java +++ b/hg-store-node/src/main/java/org/apache/hugegraph/store/node/grpc/QueryCondition.java @@ -18,7 +18,7 @@ package org.apache.hugegraph.store.node.grpc; /** - * @author lynn.bond@hotmail.com on 2023/2/8 + * 2023/2/8 */ public interface QueryCondition { byte[] getStart(); diff --git a/hg-store-node/src/main/java/org/apache/hugegraph/store/node/grpc/ScanBatchOneShotResponse.java b/hg-store-node/src/main/java/org/apache/hugegraph/store/node/grpc/ScanBatchOneShotResponse.java index 06e1f0887..685f77fac 100644 --- a/hg-store-node/src/main/java/org/apache/hugegraph/store/node/grpc/ScanBatchOneShotResponse.java +++ b/hg-store-node/src/main/java/org/apache/hugegraph/store/node/grpc/ScanBatchOneShotResponse.java @@ -36,7 +36,8 @@ import lombok.extern.slf4j.Slf4j; /** - * @author lynn.bond@hotmail.com created on 2022/04/08 + * created on 2022/04/08 + * * @version 0.1.0 */ @Slf4j diff --git a/hg-store-node/src/main/java/org/apache/hugegraph/store/node/grpc/ScanBatchResponse3.java b/hg-store-node/src/main/java/org/apache/hugegraph/store/node/grpc/ScanBatchResponse3.java index ae336b1d7..6da57804d 100644 --- a/hg-store-node/src/main/java/org/apache/hugegraph/store/node/grpc/ScanBatchResponse3.java +++ b/hg-store-node/src/main/java/org/apache/hugegraph/store/node/grpc/ScanBatchResponse3.java @@ -47,7 +47,8 @@ import io.grpc.stub.StreamObserver; import lombok.extern.slf4j.Slf4j; /** - * @author lynn.bond@hotmail.com created on 2022/03/27 + * created on 2022/03/27 + * * @version 3.6.0 */ @Slf4j diff --git a/hg-store-node/src/main/java/org/apache/hugegraph/store/node/grpc/ScanOneShotResponse.java b/hg-store-node/src/main/java/org/apache/hugegraph/store/node/grpc/ScanOneShotResponse.java index a9e7347dd..5880b71c5 100644 --- a/hg-store-node/src/main/java/org/apache/hugegraph/store/node/grpc/ScanOneShotResponse.java +++ b/hg-store-node/src/main/java/org/apache/hugegraph/store/node/grpc/ScanOneShotResponse.java @@ -33,7 +33,8 @@ import lombok.extern.slf4j.Slf4j; /** - * @author lynn.bond@hotmail.com created on 2022/02/17 + * created on 2022/02/17 + * * @version 3.6.0 */ @Slf4j diff --git a/hg-store-node/src/main/java/org/apache/hugegraph/store/node/grpc/ScanQuery.java b/hg-store-node/src/main/java/org/apache/hugegraph/store/node/grpc/ScanQuery.java index 03c4c47ba..5c1791022 100644 --- a/hg-store-node/src/main/java/org/apache/hugegraph/store/node/grpc/ScanQuery.java +++ b/hg-store-node/src/main/java/org/apache/hugegraph/store/node/grpc/ScanQuery.java @@ -22,7 +22,7 @@ import java.util.Arrays; import org.apache.hugegraph.store.grpc.common.ScanMethod; /** - * @author lynn.bond@hotmail.com on 2022/2/28 + * 2022/2/28 */ class ScanQuery implements QueryCondition { String graph; diff --git a/hg-store-node/src/main/java/org/apache/hugegraph/store/node/grpc/ScanQueryProducer.java b/hg-store-node/src/main/java/org/apache/hugegraph/store/node/grpc/ScanQueryProducer.java index 768c9eff3..963ff66f4 100644 --- a/hg-store-node/src/main/java/org/apache/hugegraph/store/node/grpc/ScanQueryProducer.java +++ b/hg-store-node/src/main/java/org/apache/hugegraph/store/node/grpc/ScanQueryProducer.java @@ -34,8 +34,8 @@ import lombok.extern.slf4j.Slf4j; /** * Buffering the data of ScanQueryRequest and generating ScanQuery. * It will not hold the reference of ScanQueryRequest. - * - * @author lynn.bond@hotmail.com on 2023/2/8 + *

+ * 2023/2/8 */ @NotThreadSafe @Slf4j diff --git a/hg-store-node/src/main/java/org/apache/hugegraph/store/node/grpc/ScanStreamResponse.java b/hg-store-node/src/main/java/org/apache/hugegraph/store/node/grpc/ScanStreamResponse.java index 42cfb56b8..16ff7f0e0 100644 --- a/hg-store-node/src/main/java/org/apache/hugegraph/store/node/grpc/ScanStreamResponse.java +++ b/hg-store-node/src/main/java/org/apache/hugegraph/store/node/grpc/ScanStreamResponse.java @@ -42,7 +42,8 @@ import io.grpc.stub.StreamObserver; import lombok.extern.slf4j.Slf4j; /** - * @author lynn.bond@hotmail.com created on 2022/02/17 + * created on 2022/02/17 + * * @version 3.6.0 */ @Slf4j diff --git a/hg-store-node/src/main/java/org/apache/hugegraph/store/node/grpc/ScanUtil.java b/hg-store-node/src/main/java/org/apache/hugegraph/store/node/grpc/ScanUtil.java index 61844eb4e..2fb2a2104 100644 --- a/hg-store-node/src/main/java/org/apache/hugegraph/store/node/grpc/ScanUtil.java +++ b/hg-store-node/src/main/java/org/apache/hugegraph/store/node/grpc/ScanUtil.java @@ -43,7 +43,8 @@ import lombok.extern.slf4j.Slf4j; /** - * @author lynn.bond@hotmail.com created on 2022/02/22 + * created on 2022/02/22 + * * @version 1.0.0 */ @Slf4j diff --git a/hg-store-node/src/main/java/org/apache/hugegraph/store/node/grpc/scan/ScanResponseObserver.java b/hg-store-node/src/main/java/org/apache/hugegraph/store/node/grpc/scan/ScanResponseObserver.java index c4bc99289..f118b1734 100644 --- a/hg-store-node/src/main/java/org/apache/hugegraph/store/node/grpc/scan/ScanResponseObserver.java +++ b/hg-store-node/src/main/java/org/apache/hugegraph/store/node/grpc/scan/ScanResponseObserver.java @@ -41,7 +41,6 @@ import io.grpc.stub.StreamObserver; import lombok.extern.slf4j.Slf4j; /** - * @author zhangyingjie * @date 2022/10/26 **/ @Slf4j @@ -97,6 +96,10 @@ public class ScanResponseObserver implements private boolean readCondition() { return packages.remainingCapacity() != 0 && !readOver.get(); + } + + private boolean readTaskCondition() { + return readCondition() && (readTask == null || readTask.isDone()); } Runnable rr = new Runnable() { @Override public void run() { @@ -141,8 +144,12 @@ public class ScanResponseObserver implements } }; - private boolean readTaskCondition() { - return readCondition() && (readTask == null || readTask.isDone()); + private boolean sendCondition() { + return nextSeqNo.get() - cltSeqNo.get() < MAX_PAGE; + } + + private boolean sendTaskCondition() { + return sendCondition() && (sendTask == null || sendTask.isDone()); } Runnable sr = () -> { while (sendCondition()) { ScanResponse response; @@ -172,14 +179,6 @@ public class ScanResponseObserver implements } }; - private boolean sendCondition() { - return nextSeqNo.get() - cltSeqNo.get() < MAX_PAGE; - } - - private boolean sendTaskCondition() { - return sendCondition() && (sendTask == null || sendTask.isDone()); - } - private void offer(Iterable data, boolean isVertex) { ScanResponse.Builder builder = ScanResponse.newBuilder(); builder.setHeader(okHeader).setSeqNo(nextSeqNo.get()); @@ -265,4 +264,6 @@ public class ScanResponseObserver implements + + } diff --git a/hg-store-node/src/main/java/org/apache/hugegraph/store/node/listener/ContextClosedListener.java b/hg-store-node/src/main/java/org/apache/hugegraph/store/node/listener/ContextClosedListener.java index 174d948cf..676b90445 100644 --- a/hg-store-node/src/main/java/org/apache/hugegraph/store/node/listener/ContextClosedListener.java +++ b/hg-store-node/src/main/java/org/apache/hugegraph/store/node/listener/ContextClosedListener.java @@ -27,7 +27,6 @@ import org.springframework.context.event.ContextClosedEvent; import lombok.extern.slf4j.Slf4j; /** - * @author zhangyingjie * @date 2023/2/17 **/ @Slf4j diff --git a/hg-store-node/src/main/java/org/apache/hugegraph/store/node/listener/PdConfigureListener.java b/hg-store-node/src/main/java/org/apache/hugegraph/store/node/listener/PdConfigureListener.java index 706c13a55..b67546198 100644 --- a/hg-store-node/src/main/java/org/apache/hugegraph/store/node/listener/PdConfigureListener.java +++ b/hg-store-node/src/main/java/org/apache/hugegraph/store/node/listener/PdConfigureListener.java @@ -46,7 +46,6 @@ import com.google.common.base.Charsets; import lombok.extern.slf4j.Slf4j; /** - * @author zhangyingjie * @date 2022/7/5 **/ @Slf4j diff --git a/hg-store-node/src/main/java/org/apache/hugegraph/store/node/metrics/DriveMetrics.java b/hg-store-node/src/main/java/org/apache/hugegraph/store/node/metrics/DriveMetrics.java index 109c702a8..9e51f62ac 100644 --- a/hg-store-node/src/main/java/org/apache/hugegraph/store/node/metrics/DriveMetrics.java +++ b/hg-store-node/src/main/java/org/apache/hugegraph/store/node/metrics/DriveMetrics.java @@ -23,7 +23,7 @@ import java.util.LinkedHashMap; import java.util.Map; /** - * @author lynn.bond@hotmail.com on 2021/11/23 + * 2021/11/23 */ @Deprecated public class DriveMetrics { diff --git a/hg-store-node/src/main/java/org/apache/hugegraph/store/node/metrics/GRpcExMetrics.java b/hg-store-node/src/main/java/org/apache/hugegraph/store/node/metrics/GRpcExMetrics.java index baaa74d8c..d9aa233f9 100644 --- a/hg-store-node/src/main/java/org/apache/hugegraph/store/node/metrics/GRpcExMetrics.java +++ b/hg-store-node/src/main/java/org/apache/hugegraph/store/node/metrics/GRpcExMetrics.java @@ -26,7 +26,7 @@ import io.micrometer.core.instrument.Gauge; import io.micrometer.core.instrument.MeterRegistry; /** - * @author lynn.bond@hotmail.com on 2022/3/8 + * 2022/3/8 */ public class GRpcExMetrics { public final static String PREFIX = "grpc"; diff --git a/hg-store-node/src/main/java/org/apache/hugegraph/store/node/metrics/JRaftMetrics.java b/hg-store-node/src/main/java/org/apache/hugegraph/store/node/metrics/JRaftMetrics.java index beb7f2406..1d7029861 100644 --- a/hg-store-node/src/main/java/org/apache/hugegraph/store/node/metrics/JRaftMetrics.java +++ b/hg-store-node/src/main/java/org/apache/hugegraph/store/node/metrics/JRaftMetrics.java @@ -41,7 +41,7 @@ import io.micrometer.core.instrument.Tag; import lombok.extern.slf4j.Slf4j; /** - * @author lynn.bond@hotmail.com on 2022/1/4 + * 2022/1/4 */ @Slf4j public class JRaftMetrics { diff --git a/hg-store-node/src/main/java/org/apache/hugegraph/store/node/metrics/MetricsConfig.java b/hg-store-node/src/main/java/org/apache/hugegraph/store/node/metrics/MetricsConfig.java index a80741ab6..801470370 100644 --- a/hg-store-node/src/main/java/org/apache/hugegraph/store/node/metrics/MetricsConfig.java +++ b/hg-store-node/src/main/java/org/apache/hugegraph/store/node/metrics/MetricsConfig.java @@ -24,7 +24,7 @@ import org.springframework.context.annotation.Configuration; import io.micrometer.core.instrument.MeterRegistry; /** - * @author lynn.bond@hotmail.com on 2021/11/24 + * 2021/11/24 */ @Configuration public class MetricsConfig { diff --git a/hg-store-node/src/main/java/org/apache/hugegraph/store/node/metrics/ProcfsMetrics.java b/hg-store-node/src/main/java/org/apache/hugegraph/store/node/metrics/ProcfsMetrics.java index 68efea41e..997b95d8e 100644 --- a/hg-store-node/src/main/java/org/apache/hugegraph/store/node/metrics/ProcfsMetrics.java +++ b/hg-store-node/src/main/java/org/apache/hugegraph/store/node/metrics/ProcfsMetrics.java @@ -22,7 +22,8 @@ import io.micrometer.core.instrument.Gauge; import io.micrometer.core.instrument.MeterRegistry; /** - * @author lynn.bond@hotmail.com on 2022/3/1 + * 2022/3/1 + * * @version 0.1.0 */ public class ProcfsMetrics { diff --git a/hg-store-node/src/main/java/org/apache/hugegraph/store/node/metrics/RocksDBMetrics.java b/hg-store-node/src/main/java/org/apache/hugegraph/store/node/metrics/RocksDBMetrics.java index f640da120..4df4b2b71 100644 --- a/hg-store-node/src/main/java/org/apache/hugegraph/store/node/metrics/RocksDBMetrics.java +++ b/hg-store-node/src/main/java/org/apache/hugegraph/store/node/metrics/RocksDBMetrics.java @@ -52,7 +52,8 @@ import io.micrometer.core.instrument.MeterRegistry; import lombok.extern.slf4j.Slf4j; /** - * @author lynn.bond@hotmail.com on 2021/12/30 + * 2021/12/30 + * * @version 1.2.0 on 2022/03/22 added auto meter removing when graph has been closed. */ @Slf4j diff --git a/hg-store-node/src/main/java/org/apache/hugegraph/store/node/metrics/RocksDBMetricsConst.java b/hg-store-node/src/main/java/org/apache/hugegraph/store/node/metrics/RocksDBMetricsConst.java index 0b8d9a9af..2fe8e40c0 100644 --- a/hg-store-node/src/main/java/org/apache/hugegraph/store/node/metrics/RocksDBMetricsConst.java +++ b/hg-store-node/src/main/java/org/apache/hugegraph/store/node/metrics/RocksDBMetricsConst.java @@ -21,7 +21,7 @@ import org.rocksdb.HistogramType; import org.rocksdb.TickerType; /** - * @author lynn.bond@hotmail.com on 2021/12/30 + * 2021/12/30 */ public final class RocksDBMetricsConst { public static final String PREFIX = "rocks.stats"; diff --git a/hg-store-node/src/main/java/org/apache/hugegraph/store/node/metrics/StoreMetrics.java b/hg-store-node/src/main/java/org/apache/hugegraph/store/node/metrics/StoreMetrics.java index af94dac7e..1abf176d7 100644 --- a/hg-store-node/src/main/java/org/apache/hugegraph/store/node/metrics/StoreMetrics.java +++ b/hg-store-node/src/main/java/org/apache/hugegraph/store/node/metrics/StoreMetrics.java @@ -30,7 +30,7 @@ import io.micrometer.core.instrument.Gauge; import io.micrometer.core.instrument.MeterRegistry; /** - * @author lynn.bond@hotmail.com on 2021/12/28 + * 2021/12/28 */ public final class StoreMetrics { public final static String PREFIX = "hg"; diff --git a/hg-store-node/src/main/java/org/apache/hugegraph/store/node/model/HgNodeStatus.java b/hg-store-node/src/main/java/org/apache/hugegraph/store/node/model/HgNodeStatus.java index 74a048526..e615d8046 100644 --- a/hg-store-node/src/main/java/org/apache/hugegraph/store/node/model/HgNodeStatus.java +++ b/hg-store-node/src/main/java/org/apache/hugegraph/store/node/model/HgNodeStatus.java @@ -20,7 +20,7 @@ package org.apache.hugegraph.store.node.model; import java.util.Objects; /** - * @author lynn.bond@hotmail.com created on 2021/11/1 + * created on 2021/11/1 */ public class HgNodeStatus { private int status; diff --git a/hg-store-node/src/main/java/org/apache/hugegraph/store/node/util/Err.java b/hg-store-node/src/main/java/org/apache/hugegraph/store/node/util/Err.java index 87efbf4b7..d810f79ac 100644 --- a/hg-store-node/src/main/java/org/apache/hugegraph/store/node/util/Err.java +++ b/hg-store-node/src/main/java/org/apache/hugegraph/store/node/util/Err.java @@ -17,9 +17,7 @@ package org.apache.hugegraph.store.node.util; -/** - * @author lynn.bond@hotmail.com - */ + class Err { private final String msg; diff --git a/hg-store-node/src/main/java/org/apache/hugegraph/store/node/util/HgAssert.java b/hg-store-node/src/main/java/org/apache/hugegraph/store/node/util/HgAssert.java index 19e58fa8d..466e24517 100644 --- a/hg-store-node/src/main/java/org/apache/hugegraph/store/node/util/HgAssert.java +++ b/hg-store-node/src/main/java/org/apache/hugegraph/store/node/util/HgAssert.java @@ -21,9 +21,7 @@ import java.util.Collection; import java.util.Map; import java.util.function.Supplier; -/** - * @author lynn.bond@hotmail.com - */ + public final class HgAssert { @Deprecated public static void isTrue(boolean expression, String message) { diff --git a/hg-store-node/src/main/java/org/apache/hugegraph/store/node/util/HgBufferProxy.java b/hg-store-node/src/main/java/org/apache/hugegraph/store/node/util/HgBufferProxy.java index be3a76ecc..358899d50 100644 --- a/hg-store-node/src/main/java/org/apache/hugegraph/store/node/util/HgBufferProxy.java +++ b/hg-store-node/src/main/java/org/apache/hugegraph/store/node/util/HgBufferProxy.java @@ -31,7 +31,8 @@ import javax.annotation.CheckForNull; import lombok.extern.slf4j.Slf4j; /** - * @author lynn.bond@hotmail.com on 2022/3/15 + * 2022/3/15 + * * @version 0.2.0 */ @Slf4j diff --git a/hg-store-node/src/main/java/org/apache/hugegraph/store/node/util/HgChannel.java b/hg-store-node/src/main/java/org/apache/hugegraph/store/node/util/HgChannel.java index aa98683c9..b51a38e10 100644 --- a/hg-store-node/src/main/java/org/apache/hugegraph/store/node/util/HgChannel.java +++ b/hg-store-node/src/main/java/org/apache/hugegraph/store/node/util/HgChannel.java @@ -30,8 +30,9 @@ import lombok.extern.slf4j.Slf4j; /** * Golang style channel without buffering + *

+ * 2022/2/28 * - * @author lynn.bond@hotmail.com on 2022/2/28 * @version 1.1 on 2022/04/02 */ @Slf4j diff --git a/hg-store-node/src/main/java/org/apache/hugegraph/store/node/util/HgExecutorUtil.java b/hg-store-node/src/main/java/org/apache/hugegraph/store/node/util/HgExecutorUtil.java index 7a67be4d6..250cc3210 100644 --- a/hg-store-node/src/main/java/org/apache/hugegraph/store/node/util/HgExecutorUtil.java +++ b/hg-store-node/src/main/java/org/apache/hugegraph/store/node/util/HgExecutorUtil.java @@ -30,7 +30,7 @@ import java.util.concurrent.atomic.AtomicInteger; import lombok.extern.slf4j.Slf4j; /** - * @author lynn.bond@hotmail.com on 2022/03/04 + * 2022/03/04 */ @Slf4j public final class HgExecutorUtil { diff --git a/hg-store-node/src/main/java/org/apache/hugegraph/store/node/util/HgGrpc.java b/hg-store-node/src/main/java/org/apache/hugegraph/store/node/util/HgGrpc.java index 206717e31..b438c8825 100644 --- a/hg-store-node/src/main/java/org/apache/hugegraph/store/node/util/HgGrpc.java +++ b/hg-store-node/src/main/java/org/apache/hugegraph/store/node/util/HgGrpc.java @@ -33,9 +33,6 @@ import io.grpc.StatusRuntimeException; import jline.internal.Log; -/** - * @author lynn.bond@hotmail.com - */ public abstract class HgGrpc { private static final ResCode OK = ResCode.RES_CODE_OK; diff --git a/hg-store-node/src/main/java/org/apache/hugegraph/store/node/util/HgRegexUtil.java b/hg-store-node/src/main/java/org/apache/hugegraph/store/node/util/HgRegexUtil.java index b40e961ce..3f243863b 100644 --- a/hg-store-node/src/main/java/org/apache/hugegraph/store/node/util/HgRegexUtil.java +++ b/hg-store-node/src/main/java/org/apache/hugegraph/store/node/util/HgRegexUtil.java @@ -23,7 +23,7 @@ import java.util.regex.Matcher; import java.util.regex.Pattern; /** - * @author lynn.bond@hotmail.com created on 2022/03/07 + * created on 2022/03/07 */ public class HgRegexUtil { diff --git a/hg-store-node/src/main/java/org/apache/hugegraph/store/node/util/HgStoreConst.java b/hg-store-node/src/main/java/org/apache/hugegraph/store/node/util/HgStoreConst.java index ee569ff85..ac5b222f7 100644 --- a/hg-store-node/src/main/java/org/apache/hugegraph/store/node/util/HgStoreConst.java +++ b/hg-store-node/src/main/java/org/apache/hugegraph/store/node/util/HgStoreConst.java @@ -21,7 +21,7 @@ import java.util.Collections; import java.util.List; /** - * @author lynn.bond@hotmail.com created on 2021/10/22 + * created on 2021/10/22 */ public final class HgStoreConst { diff --git a/hg-store-node/src/main/java/org/apache/hugegraph/store/node/util/HgStoreNodeUtil.java b/hg-store-node/src/main/java/org/apache/hugegraph/store/node/util/HgStoreNodeUtil.java index 5b33d196f..e44bf1bc4 100644 --- a/hg-store-node/src/main/java/org/apache/hugegraph/store/node/util/HgStoreNodeUtil.java +++ b/hg-store-node/src/main/java/org/apache/hugegraph/store/node/util/HgStoreNodeUtil.java @@ -24,7 +24,7 @@ import java.util.UUID; import lombok.extern.slf4j.Slf4j; /** - * @author lynn.bond@hotmail.com created on 2021/10/29 + * created on 2021/10/29 */ @Slf4j public final class HgStoreNodeUtil { diff --git a/hg-store-node/src/main/java/org/apache/hugegraph/store/node/util/Result.java b/hg-store-node/src/main/java/org/apache/hugegraph/store/node/util/Result.java index 979ef866d..a1073037b 100644 --- a/hg-store-node/src/main/java/org/apache/hugegraph/store/node/util/Result.java +++ b/hg-store-node/src/main/java/org/apache/hugegraph/store/node/util/Result.java @@ -17,9 +17,7 @@ package org.apache.hugegraph.store.node.util; -/** - * @author lynn.bond@hotmail.com - */ + public class Result { private Err err; private T t; diff --git a/hg-store-node/src/test/java/org/apache/hugegraph/store/node/metrics/JraftMetricsTest.java b/hg-store-node/src/test/java/org/apache/hugegraph/store/node/metrics/JraftMetricsTest.java index 81644a729..b8fc64747 100644 --- a/hg-store-node/src/test/java/org/apache/hugegraph/store/node/metrics/JraftMetricsTest.java +++ b/hg-store-node/src/test/java/org/apache/hugegraph/store/node/metrics/JraftMetricsTest.java @@ -25,7 +25,7 @@ import org.junit.Test; /** - * @author lynn.bond@hotmail.com on 2022/3/7 + * 2022/3/7 */ public class JraftMetricsTest { diff --git a/hg-store-rocksdb/src/main/java/org/apache/hugegraph/rocksdb/access/util/Asserts.java b/hg-store-rocksdb/src/main/java/org/apache/hugegraph/rocksdb/access/util/Asserts.java index 99ff5de75..892f315ba 100644 --- a/hg-store-rocksdb/src/main/java/org/apache/hugegraph/rocksdb/access/util/Asserts.java +++ b/hg-store-rocksdb/src/main/java/org/apache/hugegraph/rocksdb/access/util/Asserts.java @@ -19,9 +19,7 @@ package org.apache.hugegraph.rocksdb.access.util; import java.util.function.Supplier; -/** - * @author lynn.bond@hotmail.com - */ + public final class Asserts { public static void isTrue(boolean expression, String message) { diff --git a/hg-store-test/src/main/java/client/ClientTest.java b/hg-store-test/src/main/java/client/ClientTest.java index 015dde59e..c22fff804 100644 --- a/hg-store-test/src/main/java/client/ClientTest.java +++ b/hg-store-test/src/main/java/client/ClientTest.java @@ -23,7 +23,6 @@ import org.junit.Test; import lombok.extern.slf4j.Slf4j; /** - * @author zhangyingjie * @date 2022/10/18 **/ @Slf4j diff --git a/hg-store-test/src/main/java/core/CoreTest.java b/hg-store-test/src/main/java/core/CoreTest.java index 00a221962..f89033c14 100644 --- a/hg-store-test/src/main/java/core/CoreTest.java +++ b/hg-store-test/src/main/java/core/CoreTest.java @@ -23,7 +23,6 @@ import org.junit.Test; import lombok.extern.slf4j.Slf4j; /** - * @author zhangyingjie * @date 2022/10/18 **/ @Slf4j diff --git a/hg-store-test/src/main/java/service/SessionTest.java b/hg-store-test/src/main/java/service/SessionTest.java index 9e0c1cb97..dd2a8596b 100644 --- a/hg-store-test/src/main/java/service/SessionTest.java +++ b/hg-store-test/src/main/java/service/SessionTest.java @@ -22,7 +22,6 @@ import org.junit.Test; import lombok.extern.slf4j.Slf4j; /** - * @author zhangyingjie * @date 2022/11/15 **/ @Slf4j