format&clean scylladb

Author: msgui

hugegraph-server/hugegraph-scylladb/src/main/java/org/apache/hugegraph/backend/store/scylladb/ScyllaDBMetrics.java

@@ -20,7 +20,6 @@
 import java.util.Map;
 
 import org.apache.cassandra.tools.NodeProbe;
-
 import org.apache.hugegraph.backend.store.cassandra.CassandraMetrics;
 import org.apache.hugegraph.backend.store.cassandra.CassandraSessionPool;
 import org.apache.hugegraph.config.HugeConfig;

hugegraph-server/hugegraph-scylladb/src/main/java/org/apache/hugegraph/backend/store/scylladb/ScyllaDBStoreProvider.java

@@ -17,8 +17,6 @@
 
 package org.apache.hugegraph.backend.store.scylladb;
 
-import org.slf4j.Logger;
-
 import org.apache.hugegraph.backend.store.BackendFeatures;
 import org.apache.hugegraph.backend.store.BackendStore;
 import org.apache.hugegraph.backend.store.BackendStoreProvider;
@@ -30,6 +28,7 @@
 import org.apache.hugegraph.type.HugeType;
 import org.apache.hugegraph.util.E;
 import org.apache.hugegraph.util.Log;
+import org.slf4j.Logger;
 
 public class ScyllaDBStoreProvider extends CassandraStoreProvider {
 
@@ -94,7 +93,7 @@ public BackendStore loadSystemStore(HugeConfig config) {
     }
 
     public static class ScyllaDBSchemaStore
-                  extends CassandraStore.CassandraSchemaStore {
+            extends CassandraStore.CassandraSchemaStore {
 
         public ScyllaDBSchemaStore(BackendStoreProvider provider,
                                    String keyspace, String store) {
@@ -124,7 +123,7 @@ protected CassandraMetrics createMetrics(HugeConfig conf,
     }
 
     public static class ScyllaDBGraphStore
-                  extends CassandraStore.CassandraGraphStore {
+            extends CassandraStore.CassandraGraphStore {
 
         public ScyllaDBGraphStore(BackendStoreProvider provider,
                                   String keyspace, String store) {
@@ -152,7 +151,7 @@ protected CassandraMetrics createMetrics(HugeConfig conf,
     }
 
     public static class ScyllaDBSystemStore
-                  extends CassandraStore.CassandraSystemStore {
+            extends CassandraStore.CassandraSystemStore {
 
         public ScyllaDBSystemStore(BackendStoreProvider provider,
                                    String keyspace, String store) {

hugegraph-server/hugegraph-scylladb/src/main/java/org/apache/hugegraph/backend/store/scylladb/ScyllaDBTablesWithMV.java

@@ -29,6 +29,7 @@
 import org.apache.hugegraph.backend.store.cassandra.CassandraTables;
 import org.apache.hugegraph.type.define.Directions;
 import org.apache.hugegraph.type.define.HugeKeys;
+
 import com.datastax.driver.core.querybuilder.Select;
 
 public class ScyllaDBTablesWithMV {
@@ -62,17 +63,17 @@ private static String mvLabelTable(String table) {
     }
 
     private static void createSchemaIndexTable(
-                        CassandraSessionPool.Session session,
-                        String mvName, String table) {
+            CassandraSessionPool.Session session,
+            String mvName, String table) {
         final String NAME = CassandraTable.formatKey(HugeKeys.NAME);
         final String ID = CassandraTable.formatKey(HugeKeys.ID);
         String cql = String.format(
-                     "CREATE MATERIALIZED VIEW IF NOT EXISTS %s AS " +
-                     "  SELECT * FROM %s " +
-                     "  WHERE %s IS NOT NULL " +
-                     "  PRIMARY KEY(%s, %s)",
-                     mvName, table, NAME,
-                     NAME, ID);
+                "CREATE MATERIALIZED VIEW IF NOT EXISTS %s AS " +
+                "  SELECT * FROM %s " +
+                "  WHERE %s IS NOT NULL " +
+                "  PRIMARY KEY(%s, %s)",
+                mvName, table, NAME,
+                NAME, ID);
         session.execute(cql);
     }
 
@@ -206,11 +207,11 @@ protected void createIndex(CassandraSessionPool.Session session,
             final String LABEL = CassandraTable.formatKey(HugeKeys.LABEL);
             final String ID = CassandraTable.formatKey(HugeKeys.ID);
             String cql = String.format(
-                         "CREATE MATERIALIZED VIEW IF NOT EXISTS %s AS " +
-                         "  SELECT * FROM %s " +
-                         "  WHERE %s IS NOT NULL " +
-                         "  PRIMARY KEY(%s, %s)",
-                         mvLabel2Vertex, this.table(), LABEL, LABEL, ID);
+                    "CREATE MATERIALIZED VIEW IF NOT EXISTS %s AS " +
+                    "  SELECT * FROM %s " +
+                    "  WHERE %s IS NOT NULL " +
+                    "  PRIMARY KEY(%s, %s)",
+                    mvLabel2Vertex, this.table(), LABEL, LABEL, ID);
             session.execute(cql);
         }
 
@@ -240,13 +241,13 @@ public static class Edge extends CassandraTables.Edge {
 
         private static final String LABEL = CassandraTable.formatKey(HugeKeys.LABEL);
         private final List<String> keys = this.idColumnName().stream()
-                                          .filter(k -> k != HugeKeys.LABEL)
-                                          .map(k -> CassandraTable.formatKey(k))
-                                          .collect(Collectors.toList());
+                                              .filter(k -> k != HugeKeys.LABEL)
+                                              .map(k -> CassandraTable.formatKey(k))
+                                              .collect(Collectors.toList());
         private final String prKeys = this.keys.stream()
-                                      .collect(Collectors.joining(","));
+                                               .collect(Collectors.joining(","));
         private final String prkeysNn = this.keys.stream().collect(
-                             Collectors.joining(" IS NOT NULL AND "));
+                Collectors.joining(" IS NOT NULL AND "));
 
         public Edge(String store, Directions direction) {
             super(store, direction);
@@ -257,13 +258,13 @@ protected void createIndex(CassandraSessionPool.Session session,
                                    String indexLabel,
                                    HugeKeys column) {
             String cql = String.format(
-                         "CREATE MATERIALIZED VIEW IF NOT EXISTS %s AS " +
-                         "  SELECT * FROM %s " +
-                         "  WHERE %s IS NOT NULL AND %s IS NOT NULL " +
-                         "  PRIMARY KEY(%s, %s)",
-                         mvLabel2Edge, this.table(),
-                         this.LABEL, this.prkeysNn,
-                         this.LABEL, this.prKeys);
+                    "CREATE MATERIALIZED VIEW IF NOT EXISTS %s AS " +
+                    "  SELECT * FROM %s " +
+                    "  WHERE %s IS NOT NULL AND %s IS NOT NULL " +
+                    "  PRIMARY KEY(%s, %s)",
+                    mvLabel2Edge, this.table(),
+                    LABEL, this.prkeysNn,
+                    LABEL, this.prKeys);
             session.execute(cql);
         }