refact: clean code & typo & update the name of getTimeZone

.github/ISSUE_TEMPLATE/bug_report.yml

@@ -28,7 +28,7 @@ body:
       options:
         - exception / error (异常报错)
         - logic (逻辑设计问题)
-        - performence (性能下降)
+        - performance (性能下降)
         - others (please edit later)
 
   - type: checkboxes

.github/ISSUE_TEMPLATE/question_ask.yml

@@ -25,7 +25,7 @@ body:
       label: Problem Type (问题类型)
       options:
         - struct / logic (架构 / 逻辑设计问题)
-        - performence (性能优化)
+        - performance (性能优化)
         - exception / error (异常报错)
         - others (please edit later)
 

hugegraph-common/src/main/java/org/apache/hugegraph/concurrent/KeyLock.java

@@ -88,16 +88,16 @@ public final List<Lock> lockAll(Object... keys) {
             Lock lock = this.locks.get(key);
             locks.add(lock);
         }
-        Collections.sort(locks, (a, b) -> {
+        locks.sort((a, b) -> {
             int diff = a.hashCode() - b.hashCode();
             if (diff == 0 && a != b) {
                 diff = this.indexOf(a) - this.indexOf(b);
                 assert diff != 0;
             }
             return diff;
         });
-        for (int i = 0; i < locks.size(); i++) {
-            locks.get(i).lock();
+        for (Lock lock : locks) {
+            lock.lock();
         }
         return Collections.unmodifiableList(locks);
     }
@@ -125,8 +125,8 @@ public List<Lock> lockAll(Object key1, Object key2) {
                            ImmutableList.of(lock2, lock1) :
                            ImmutableList.of(lock1, lock2);
 
-        for (int i = 0; i < locks.size(); i++) {
-            locks.get(i).lock();
+        for (Lock lock : locks) {
+            lock.lock();
         }
 
         return locks;

hugegraph-common/src/main/java/org/apache/hugegraph/concurrent/PausableScheduledThreadPool.java

@@ -28,8 +28,7 @@
 
 public class PausableScheduledThreadPool extends ScheduledThreadPoolExecutor {
 
-    private static final Logger LOG = Log.logger(
-                                      PausableScheduledThreadPool.class);
+    private static final Logger LOG = Log.logger(PausableScheduledThreadPool.class);
 
     private volatile boolean paused = false;
 

hugegraph-common/src/main/java/org/apache/hugegraph/config/OptionChecker.java

@@ -21,6 +21,7 @@
 
 import java.lang.reflect.Array;
 import java.util.Arrays;
+import java.util.HashSet;
 import java.util.List;
 
 import javax.annotation.Nullable;
@@ -32,88 +33,55 @@
 public final class OptionChecker {
 
     public static <O> Predicate<O> disallowEmpty() {
-        return new Predicate<O>() {
-            @Override
-            public boolean apply(@Nullable O o) {
-                if (o == null) {
-                    return false;
-                }
-                if (o instanceof String) {
-                    return StringUtils.isNotBlank((String) o);
-                }
-                if (o.getClass().isArray() && (Array.getLength(o) == 0)) {
-                    return false;
-                }
-                if (o instanceof Iterable &&
-                    !((Iterable<?>) o).iterator().hasNext()) {
-                    return false;
-                }
-                return true;
+        return o -> {
+            if (o == null) {
+                return false;
             }
+            if (o instanceof String) {
+                return StringUtils.isNotBlank((String) o);
+            }
+            if (o.getClass().isArray() && (Array.getLength(o) == 0)) {
+                return false;
+            }
+            return !(o instanceof Iterable) || ((Iterable<?>) o).iterator().hasNext();
         };
     }
 
     @SuppressWarnings("unchecked")
     public static <O> Predicate<O> allowValues(O... values) {
-        return new Predicate<O>() {
-            @Override
-            public boolean apply(@Nullable O o) {
-                return o != null && Arrays.asList(values).contains(o);
-            }
-        };
+        return o -> o != null && Arrays.asList(values).contains(o);
     }
 
     @SuppressWarnings("unchecked")
     public static <O> Predicate<List<O>> inValues(O... values) {
-        return new Predicate<List<O>>() {
-            @Override
-            public boolean apply(@Nullable List<O> o) {
-                return o != null && Arrays.asList(values).containsAll(o);
-            }
-        };
+        return o -> o != null && new HashSet<>(Arrays.asList(values)).containsAll(o);
     }
 
     public static <N extends Number> Predicate<N> positiveInt() {
-        return new Predicate<N>() {
-            @Override
-            public boolean apply(@Nullable N number) {
-                return number != null && number.longValue() > 0;
-            }
-        };
+        return number -> number != null && number.longValue() > 0;
     }
 
     public static <N extends Number> Predicate<N> nonNegativeInt() {
-        return new Predicate<N>() {
-            @Override
-            public boolean apply(@Nullable N number) {
-                return number != null && number.longValue() >= 0;
-            }
-        };
+        return number -> number != null && number.longValue() >= 0;
     }
 
     public static <N extends Number> Predicate<N> rangeInt(N min, N max) {
-        return new Predicate<N>() {
-            @Override
-            public boolean apply(@Nullable N number) {
-                if (number == null) {
-                    return false;
-                }
-                long value = number.longValue();
-                return value >= min.longValue() && value <= max.longValue();
+        return number -> {
+            if (number == null) {
+                return false;
             }
+            long value = number.longValue();
+            return value >= min.longValue() && value <= max.longValue();
         };
     }
 
     public static <N extends Number> Predicate<N> rangeDouble(N min, N max) {
-        return new Predicate<N>() {
-            @Override
-            public boolean apply(@Nullable N number) {
-                if (number == null) {
-                    return false;
-                }
-                double value = number.doubleValue();
-                return value >= min.doubleValue() && value <= max.doubleValue();
+        return number -> {
+            if (number == null) {
+                return false;
             }
+            double value = number.doubleValue();
+            return value >= min.doubleValue() && value <= max.doubleValue();
         };
     }
 }

hugegraph-common/src/main/java/org/apache/hugegraph/date/SafeDateFormat.java

@@ -48,7 +48,7 @@ public synchronized void setTimeZone(String zoneId) {
         this.formatter = this.formatter.withZone(zone);
     }
 
-    public TimeZone getTimeZome() {
+    public TimeZone getTimeZone() {
         return this.formatter.getZone().toTimeZone();
     }
 

hugegraph-common/src/main/java/org/apache/hugegraph/event/EventHub.java

@@ -159,8 +159,8 @@ public Future<Integer> notify(String event, @Nullable Object... args) {
                 try {
                     all.next().event(ev);
                     count++;
-                } catch (Throwable ignored) {
-                    LOG.warn("Failed to handle event: {}", ev, ignored);
+                } catch (Throwable e) {
+                    LOG.warn("Failed to handle event: {}", ev, e);
                 }
             }
             return count;

hugegraph-common/src/main/java/org/apache/hugegraph/event/EventListener.java

@@ -25,5 +25,5 @@ public interface EventListener extends java.util.EventListener {
      * @param event object
      * @return event result
      */
-    public Object event(Event event);
+    Object event(Event event);
 }

hugegraph-common/src/main/java/org/apache/hugegraph/func/TriFunction.java

@@ -20,5 +20,6 @@
 package org.apache.hugegraph.func;
 
 public interface TriFunction <T1, T2, T3, R> {
-    public R apply(T1 v1, T2 v2, T3 v3);
+
+    R apply(T1 v1, T2 v2, T3 v3);
 }

hugegraph-common/src/main/java/org/apache/hugegraph/iterator/ExtendableIterator.java

@@ -82,7 +82,7 @@ protected boolean fetch() {
             return true;
         }
 
-        Iterator<T> first = null;
+        Iterator<T> first;
         while ((first = this.itors.peekFirst()) != null && !first.hasNext()) {
             if (first == this.itors.peekLast() && this.itors.size() == 1) {
                 this.currentIterator = first;

hugegraph-common/src/main/java/org/apache/hugegraph/iterator/Metadatable.java

@@ -21,5 +21,5 @@
 
 public interface Metadatable {
 
-    public Object metadata(String meta, Object... args);
+    Object metadata(String meta, Object... args);
 }

hugegraph-common/src/main/java/org/apache/hugegraph/license/LicenseManager.java

@@ -21,14 +21,14 @@
 
 public interface LicenseManager {
 
-    public LicenseParams installLicense() throws Exception;
+    LicenseParams installLicense() throws Exception;
 
-    public void uninstallLicense() throws Exception;
+    void uninstallLicense() throws Exception;
 
-    public LicenseParams verifyLicense() throws Exception;
+    LicenseParams verifyLicense() throws Exception;
 
-    public interface VerifyCallback {
+    interface VerifyCallback {
 
-        public void onVerifyLicense(LicenseParams params) throws Exception;
+        void onVerifyLicense(LicenseParams params) throws Exception;
     }
 }

hugegraph-common/src/main/java/org/apache/hugegraph/perf/LightStopwatch.java

@@ -135,8 +135,7 @@ public long totalChildrenWasted() {
     @Override
     public void fillChildrenTotal(List<Stopwatch> children) {
         // Fill total times of children
-        this.totalChildrenTimes = children.stream().mapToLong(
-                                  c -> c.totalTimes()).sum();
+        this.totalChildrenTimes = children.stream().mapToLong(Stopwatch::totalTimes).sum();
     }
 
     @Override

hugegraph-common/src/main/java/org/apache/hugegraph/perf/NormalStopwatch.java

@@ -184,11 +184,9 @@ public long totalChildrenWasted() {
     @Override
     public void fillChildrenTotal(List<Stopwatch> children) {
         // Fill total wasted cost of children
-        this.totalChildrenWasted = children.stream().mapToLong(
-                                   c -> c.totalWasted()).sum();
+        this.totalChildrenWasted = children.stream().mapToLong(Stopwatch::totalWasted).sum();
         // Fill total times of children
-        this.totalChildrenTimes = children.stream().mapToLong(
-                                  c -> c.totalTimes()).sum();
+        this.totalChildrenTimes = children.stream().mapToLong(Stopwatch::totalTimes).sum();
     }
 
     @Override

hugegraph-common/src/main/java/org/apache/hugegraph/perf/PerfUtil.java

@@ -681,8 +681,8 @@ public void clear() {
 
     @Retention(RetentionPolicy.RUNTIME)
     @Target({ ElementType.METHOD, ElementType.CONSTRUCTOR })
-    public static @interface Watched {
-        public String value() default "";
-        public String prefix() default "";
+    public @interface Watched {
+        String value() default "";
+        String prefix() default "";
     }
 }

hugegraph-common/src/main/java/org/apache/hugegraph/perf/Stopwatch.java

@@ -23,40 +23,40 @@
 
 public interface Stopwatch extends Cloneable {
 
-    public Path id();
-    public String name();
-    public Path parent();
+    Path id();
+    String name();
+    Path parent();
 
-    public void startTime(long startTime);
-    public void endTime(long startTime);
+    void startTime(long startTime);
+    void endTime(long startTime);
 
-    public void lastStartTime(long startTime);
+    void lastStartTime(long startTime);
 
-    public long times();
-    public long totalTimes();
-    public long totalChildrenTimes();
+    long times();
+    long totalTimes();
+    long totalChildrenTimes();
 
-    public long totalCost();
-    public void totalCost(long otherCost);
+    long totalCost();
+    void totalCost(long otherCost);
 
-    public long minCost();
-    public long maxCost();
+    long minCost();
+    long maxCost();
 
-    public long totalWasted();
-    public long totalSelfWasted();
-    public long totalChildrenWasted();
+    long totalWasted();
+    long totalSelfWasted();
+    long totalChildrenWasted();
 
-    public void fillChildrenTotal(List<Stopwatch> children);
+    void fillChildrenTotal(List<Stopwatch> children);
 
-    public Stopwatch copy();
+    Stopwatch copy();
 
-    public Stopwatch child(String name);
-    public Stopwatch child(String name, Stopwatch watch);
+    Stopwatch child(String name);
+    Stopwatch child(String name, Stopwatch watch);
 
-    public boolean empty();
-    public void clear();
+    boolean empty();
+    void clear();
 
-    public default String toJson() {
+    default String toJson() {
         int len = 200 + this.name().length() + this.parent().length();
         StringBuilder sb = new StringBuilder(len);
         sb.append("{");
@@ -75,14 +75,14 @@ public default String toJson() {
         return sb.toString();
     }
 
-    public static Path id(Path parent, String name) {
+    static Path id(Path parent, String name) {
         if (parent == Path.EMPTY && name == Path.ROOT_NAME) {
             return Path.EMPTY;
         }
         return new Path(parent, name);
     }
 
-    public static final class Path implements Comparable<Path> {
+    final class Path implements Comparable<Path> {
 
         public static final String ROOT_NAME = "root";
         public static final Path EMPTY = new Path("");

hugegraph-common/src/main/java/org/apache/hugegraph/rest/AbstractRestClient.java

@@ -435,11 +435,11 @@ private static PoolingHttpClientConnectionManager connectionManager(
                                                       String url,
                                                       ClientConfig conf) {
         String protocol = (String) conf.getProperty("protocol");
-        if (protocol == null || protocol.equals("http")) {
+        if (protocol == null || "http".equals(protocol)) {
             return new PoolingHttpClientConnectionManager(TTL, TimeUnit.HOURS);
         }
 
-        assert protocol.equals("https");
+        assert "https".equals(protocol);
         String trustStoreFile = (String) conf.getProperty("trustStoreFile");
         E.checkArgument(trustStoreFile != null && !trustStoreFile.isEmpty(),
                         "The trust store file must be set when use https");