feat/release 0.5.1 (#20)

* chore: minor refactor

* 0.5.1

Author: fengjiachun

docs/metrics-display.md

@@ -50,7 +50,7 @@ By default, 2 files are generated in the program's working directory
 ```
 --- GreptimeDB Client ---
 id=1
-version=0.5.0
+version=0.5.1
 endpoints=[127.0.0.1:4001]
 database=public
 rpcOptions=RpcOptions{useRpcSharedPool=false, defaultRpcTimeout=10000, maxInboundMessageSize=268435456, flowControlWindow=268435456, idleTimeoutSeconds=300, keepAliveTimeSeconds=9223372036854775807, keepAliveTimeoutSeconds=3, keepAliveWithoutCalls=false, limitKind=None, initialLimit=64, maxLimit=1024, longRttWindow=100, smoothing=0.2, blockOnLimit=false, logOnLimitChange=true, enableMetricInterceptor=false}

ingester-all/pom.xml

@@ -4,7 +4,7 @@
     <parent>
         <artifactId>greptimedb-ingester</artifactId>
         <groupId>io.greptime</groupId>
-        <version>0.5.0</version>
+        <version>0.5.1</version>
     </parent>
 
     <artifactId>ingester-all</artifactId>

ingester-common/pom.xml

@@ -4,7 +4,7 @@
     <parent>
         <artifactId>greptimedb-ingester</artifactId>
         <groupId>io.greptime</groupId>
-        <version>0.5.0</version>
+        <version>0.5.1</version>
     </parent>
 
     <artifactId>ingester-common</artifactId>

ingester-common/src/main/java/com/google/protobuf/ByteStringHelper.java

@@ -19,7 +19,7 @@
 import java.nio.ByteBuffer;
 
 /**
- * A {@code ByteString} helper.
+ * A {@code ByteString} helper, avoid some memory copying to improve performance.
  *
  * @author jiachun.fjc
  */

ingester-common/src/main/java/io/greptime/common/Keys.java

@@ -16,13 +16,15 @@
 package io.greptime.common;
 
 /**
- * System properties option keys
+ * Constant string keys.
  *
  * @author jiachun.fjc
  */
 public final class Keys {
     public static final String DB_NAME = "GreptimeDB";
     public static final String VERSION_KEY = "client.version";
+    public static final String ID_KEY = "client.id";
+    public static final String NODE_KEY = "client.node";
     public static final String OS_NAME = "os.name";
     public static final String USE_OS_SIGNAL = "greptimedb.use_os_signal";
     public static final String AVAILABLE_CPUS = "greptimedb.available_cpus";

ingester-common/src/main/java/io/greptime/common/Streamable.java

@@ -19,6 +19,10 @@
 
 /**
  * File signal.
+ * <p>
+ * Adopt the method of creating files with specified names to interact
+ * with the Client process and implement signal transmission, achieve the
+ * purpose of controlling the process to output specified content through this.
  *
  * @author jiachun.fjc
  */

ingester-common/src/main/java/io/greptime/common/signal/FileSignal.java

@@ -32,6 +32,7 @@ public DirectExecutor(String name) {
         this.executeTimer = MetricsUtil.timer("direct_executor_timer", name);
     }
 
+    @SuppressWarnings("NullableProblems")
     @Override
     public void execute(Runnable cmd) {
         this.executeTimer.time(cmd);

ingester-common/src/main/java/io/greptime/common/util/DirectExecutor.java

@@ -38,26 +38,10 @@ public class LogScheduledThreadPoolExecutor extends ScheduledThreadPoolExecutor
     private final int corePoolSize;
     private final String name;
 
-    public LogScheduledThreadPoolExecutor(int corePoolSize, String name) {
-        super(corePoolSize);
-        this.corePoolSize = corePoolSize;
-        this.name = name;
-    }
-
-    public LogScheduledThreadPoolExecutor(int corePoolSize, ThreadFactory threadFactory, String name) {
-        super(corePoolSize, threadFactory);
-        this.corePoolSize = corePoolSize;
-        this.name = name;
-    }
-
-    public LogScheduledThreadPoolExecutor(int corePoolSize, RejectedExecutionHandler handler, String name) {
-        super(corePoolSize, handler);
-        this.corePoolSize = corePoolSize;
-        this.name = name;
-    }
-
-    public LogScheduledThreadPoolExecutor(int corePoolSize, ThreadFactory threadFactory,
-            RejectedExecutionHandler handler, String name) {
+    public LogScheduledThreadPoolExecutor(int corePoolSize, //
+            ThreadFactory threadFactory, //
+            RejectedExecutionHandler handler, //
+            String name) {
         super(corePoolSize, threadFactory, handler);
         this.corePoolSize = corePoolSize;
         this.name = name;

ingester-common/src/main/java/io/greptime/common/util/LogScheduledThreadPoolExecutor.java

@@ -40,8 +40,13 @@ public class LogThreadPoolExecutor extends ThreadPoolExecutor {
     private final int maximumPoolSize;
     private final String name;
 
-    public LogThreadPoolExecutor(int corePoolSize, int maximumPoolSize, long keepAliveTime, TimeUnit unit,
-            BlockingQueue<Runnable> workQueue, ThreadFactory threadFactory, RejectedExecutionHandler handler,
+    public LogThreadPoolExecutor(int corePoolSize, //
+            int maximumPoolSize, //
+            long keepAliveTime, //
+            TimeUnit unit, //
+            BlockingQueue<Runnable> workQueue, //
+            ThreadFactory threadFactory, //
+            RejectedExecutionHandler handler, //
             String name) {
         super(corePoolSize, maximumPoolSize, keepAliveTime, unit, workQueue, threadFactory, handler);
         this.corePoolSize = corePoolSize;