diff --git a/hugegraph-cassandra/src/main/java/com/baidu/hugegraph/backend/store/cassandra/CassandraSessionPool.java b/hugegraph-cassandra/src/main/java/com/baidu/hugegraph/backend/store/cassandra/CassandraSessionPool.java index 232fa85492..495eef83be 100644 --- a/hugegraph-cassandra/src/main/java/com/baidu/hugegraph/backend/store/cassandra/CassandraSessionPool.java +++ b/hugegraph-cassandra/src/main/java/com/baidu/hugegraph/backend/store/cassandra/CassandraSessionPool.java @@ -213,7 +213,9 @@ private void tryOpen() { assert this.session == null; try { this.open(); - } catch (InvalidQueryException ignored) {} + } catch (InvalidQueryException ignored) { + // ignore + } } @Override diff --git a/hugegraph-cassandra/src/main/java/com/baidu/hugegraph/backend/store/cassandra/CassandraShard.java b/hugegraph-cassandra/src/main/java/com/baidu/hugegraph/backend/store/cassandra/CassandraShard.java index 4e3387b995..b0e970b965 100644 --- a/hugegraph-cassandra/src/main/java/com/baidu/hugegraph/backend/store/cassandra/CassandraShard.java +++ b/hugegraph-cassandra/src/main/java/com/baidu/hugegraph/backend/store/cassandra/CassandraShard.java @@ -208,8 +208,8 @@ private Map getSubSplits(TokenRange tokenRange, private Map> getRangeMap() { Metadata metadata = this.session.metadata(); return metadata.getTokenRanges().stream().collect(Collectors.toMap( - p -> p, - p -> metadata.getReplicas('"' + this.keyspace + '"', p))); + p -> p, + p -> metadata.getReplicas('"' + this.keyspace + '"', p))); } private static Map describeSplits( diff --git a/hugegraph-cassandra/src/main/java/com/baidu/hugegraph/backend/store/cassandra/CassandraStore.java b/hugegraph-cassandra/src/main/java/com/baidu/hugegraph/backend/store/cassandra/CassandraStore.java index 0f37c92f89..90dcd5af49 100644 --- a/hugegraph-cassandra/src/main/java/com/baidu/hugegraph/backend/store/cassandra/CassandraStore.java +++ b/hugegraph-cassandra/src/main/java/com/baidu/hugegraph/backend/store/cassandra/CassandraStore.java @@ -475,12 +475,12 @@ protected boolean existsKeyspace() { } protected boolean existsTable(String table) { - KeyspaceMetadata keyspace = this.cluster().getMetadata() + KeyspaceMetadata keyspace = this.cluster().getMetadata() .getKeyspace(this.keyspace); - if (keyspace != null && keyspace.getTable(table) != null) { - return true; - } - return false; + if (keyspace != null && keyspace.getTable(table) != null) { + return true; + } + return false; } protected void initKeyspace() { diff --git a/hugegraph-cassandra/src/main/java/com/baidu/hugegraph/backend/store/cassandra/CassandraTable.java b/hugegraph-cassandra/src/main/java/com/baidu/hugegraph/backend/store/cassandra/CassandraTable.java index 299f5eea0f..548726b4a4 100644 --- a/hugegraph-cassandra/src/main/java/com/baidu/hugegraph/backend/store/cassandra/CassandraTable.java +++ b/hugegraph-cassandra/src/main/java/com/baidu/hugegraph/backend/store/cassandra/CassandraTable.java @@ -107,12 +107,12 @@ public Number queryNumber(CassandraSessionPool.Session session, statement.setReadTimeoutMillis(timeout * 1000); return session.query(statement); }, (q, rs) -> { - Row row = rs.one(); - if (row == null) { - return IteratorUtils.of(aggregate.defaultValue()); - } - return IteratorUtils.of(row.getLong(0)); - }); + Row row = rs.one(); + if (row == null) { + return IteratorUtils.of(aggregate.defaultValue()); + } + return IteratorUtils.of(row.getLong(0)); + }); return aggregate.reduce(results); }