diff --git a/hugegraph-api/pom.xml b/hugegraph-api/pom.xml
index bdf5c3e592..381a9430c9 100644
--- a/hugegraph-api/pom.xml
+++ b/hugegraph-api/pom.xml
@@ -185,6 +185,7 @@
+
0.69.0.0
diff --git a/hugegraph-api/src/main/java/org/apache/hugegraph/version/ApiVersion.java b/hugegraph-api/src/main/java/org/apache/hugegraph/version/ApiVersion.java
index 7265d3b6bf..7c793989f5 100644
--- a/hugegraph-api/src/main/java/org/apache/hugegraph/version/ApiVersion.java
+++ b/hugegraph-api/src/main/java/org/apache/hugegraph/version/ApiVersion.java
@@ -24,38 +24,35 @@
public final class ApiVersion {
- /**
+ /*
* API Version change log
- *
+ *
* version 0.2:
* [0.2] HugeGraph-527: First add the version to the hugegraph module
* [0.3] HugeGraph-525: Add versions check of components and api
- * [0.4] HugeGraph-162: Add schema builder to separate client and
- * inner interface.
+ * [0.4] HugeGraph-162: Add schema builder to separate client and inner interface.
* [0.5] HugeGraph-498: Support three kind of id strategy
- *
+ *
* version 0.3:
- *
- * [0.6] HugeGraph-614: Add update api of VL/EL to support append and
- * eliminate action
+ *
+ * [0.6] HugeGraph-614: Add update api of VL/EL to support append and eliminate action
* [0.7] HugeGraph-245: Add nullable-props for vertex label and edge label
* [0.8] HugeGraph-396: Continue to improve variables implementation
- * [0.9] HugeGraph-894: Add vertex/edge update api to add property and
- * remove property
+ * [0.9] HugeGraph-894: Add vertex/edge update api to add property and remove property
* [0.10] HugeGraph-919: Add condition query for vertex/edge list API
- *
+ *
* version 0.4:
- * [0.11] HugeGraph-938: Remove useless indexnames field in VL/EL API
+ * [0.11] HugeGraph-938: Remove useless index-names field in VL/EL API
* [0.12] HugeGraph-589: Add schema id for all schema element
* [0.13] HugeGraph-956: Support customize string/number id strategy
- *
+ *
* version 0.5:
* [0.14] HugeGraph-1085: Add enable_label_index to VL/EL
* [0.15] HugeGraph-1105: Support paging for large amounts of records
* [0.16] HugeGraph-944: Support rest shortest path, k-out, k-neighbor
* [0.17] HugeGraph-944: Support rest shortest path, k-out, k-neighbor
* [0.18] HugeGraph-81: Change argument "checkVertex" to "check_vertex"
- *
+ *
* version 0.6:
* [0.19] HugeGraph-1195: Support eliminate userdata on schema
* [0.20] HugeGraph-1210: Add paths api to find paths between two nodes
@@ -67,13 +64,13 @@ public final class ApiVersion {
* [0.26] HugeGraph-1273: Add some monitoring counters to integrate with
* gremlin's monitoring framework
* [0.27] HugeGraph-889: Use asynchronous mechanism to do schema deletion
- *
+ *
* version 0.8:
* [0.28] Issue-153: Add task-cancel API
* [0.29] Issue-39: Add rays and rings RESTful API
* [0.30] Issue-32: Change index create API to return indexLabel and task id
* [0.31] Issue-182: Support restore graph in restoring and merging mode
- *
+ *
* version 0.9:
* [0.32] Issue-250: Keep depth and degree consistent for traverser api
* [0.33] Issue-305: Implement customized paths and crosspoints RESTful API
@@ -81,21 +78,21 @@ public final class ApiVersion {
* [0.35] Issue-287: Support pagination when do index query
* [0.36] Issue-360: Support paging for scan api
* [0.37] Issue-391: Add skip_super_node for shortest path
- * [0.38] Issue-274: Add personalrank and neighborrank RESTful API
- *
+ * [0.38] Issue-274: Add personal-rank and neighbor-rank RESTful API
+ *
* version 0.10:
* [0.39] Issue-522: Add profile RESTful API
* [0.40] Issue-523: Add source_in_ring args for rings RESTful API
* [0.41] Issue-493: Support batch updating properties by multiple strategy
* [0.42] Issue-176: Let gremlin error response consistent with RESTful's
- * [0.43] Issue-270 & 398: support shard-index and vertex + sortkey prefix,
+ * [0.43] Issue-270 & 398: support shard-index and vertex + sort-key prefix,
* and split range to rangeInt, rangeFloat, rangeLong and rangeDouble
* [0.44] Issue-633: Support unique index
* [0.45] Issue-673: Add 'OVERRIDE' update strategy
* [0.46] Issue-618 & 694: Support UUID id type
* [0.47] Issue-691: Support aggregate property
* [0.48] Issue-686: Support get schema by names
- *
+ *
* version 0.11:
* [0.49] Issue-670: Support fusiform similarity API
* [0.50] Issue-746: Support userdata for index label
@@ -121,11 +118,15 @@ public final class ApiVersion {
* [0.69] Issue-1748: Support Cypher query RESTful API
*/
- // The second parameter of Version.of() is for IDE running without JAR
+ /**
+ * The second parameter of Version.of() is for IDE running without JAR
+ * TODO: what shall we set for this version? (consider the basic compatibility)
+ */
public static final Version VERSION = Version.of(ApiVersion.class, "0.69");
public static void check() {
// Check version of hugegraph-core. Firstly do check from version 0.3
+ // TODO: what shall we set for this version? (consider the basic compatibility)
VersionUtil.check(CoreVersion.VERSION, "0.13", "0.14", CoreVersion.NAME);
}
}
diff --git a/hugegraph-cassandra/src/main/java/com/datastax/driver/core/querybuilder/Clauses.java b/hugegraph-cassandra/src/main/java/com/datastax/driver/core/querybuilder/Clauses.java
index a4fa3768e3..81b88c1c4f 100644
--- a/hugegraph-cassandra/src/main/java/com/datastax/driver/core/querybuilder/Clauses.java
+++ b/hugegraph-cassandra/src/main/java/com/datastax/driver/core/querybuilder/Clauses.java
@@ -28,8 +28,7 @@
public class Clauses {
public static boolean needAllowFiltering(Clause clause) {
- return ContainsKeyClause.class.isInstance(clause) ||
- ContainsClause.class.isInstance(clause);
+ return clause instanceof ContainsKeyClause || clause instanceof ContainsClause;
}
public static Clause and(Clause left, Clause right) {
@@ -42,9 +41,9 @@ public static Clause in(String name, List> values) {
static class BinClause extends Clause {
- private Clause left;
- private String op;
- private Clause right;
+ private final Clause left;
+ private final String op;
+ private final Clause right;
public BinClause(Clause left, String op, Clause right) {
this.left = left;
@@ -64,11 +63,7 @@ Object firstValue() {
@Override
boolean containsBindMarker() {
- if (Utils.containsBindMarker(this.left) ||
- Utils.containsBindMarker(this.right)) {
- return true;
- }
- return false;
+ return Utils.containsBindMarker(this.left) || Utils.containsBindMarker(this.right);
}
@Override
@@ -89,7 +84,7 @@ void appendTo(StringBuilder sb, List variables,
static class AndClause extends BinClause {
public AndClause(Clause left, Clause right) {
- super(left, "AND", right);
+ super(left, "AND", right);
}
}
}
diff --git a/hugegraph-cassandra/src/main/java/org/apache/hugegraph/backend/store/cassandra/CassandraEntryIterator.java b/hugegraph-cassandra/src/main/java/org/apache/hugegraph/backend/store/cassandra/CassandraEntryIterator.java
index 48d0ca2ad9..a46b327f03 100644
--- a/hugegraph-cassandra/src/main/java/org/apache/hugegraph/backend/store/cassandra/CassandraEntryIterator.java
+++ b/hugegraph-cassandra/src/main/java/org/apache/hugegraph/backend/store/cassandra/CassandraEntryIterator.java
@@ -28,6 +28,7 @@
import org.apache.hugegraph.backend.store.BackendEntry;
import org.apache.hugegraph.backend.store.BackendEntryIterator;
import org.apache.hugegraph.util.E;
+
import com.datastax.driver.core.ExecutionInfo;
import com.datastax.driver.core.PagingState;
import com.datastax.driver.core.ResultSet;
@@ -39,7 +40,7 @@ public class CassandraEntryIterator extends BackendEntryIterator {
private final Iterator rows;
private final BiFunction merger;
- private int fetchdPageSize;
+ private int fetchedPageSize;
private long expected;
private BackendEntry next;
@@ -50,7 +51,7 @@ public CassandraEntryIterator(ResultSet results, Query query,
this.rows = results.iterator();
this.merger = merger;
- this.fetchdPageSize = results.getAvailableWithoutFetching();
+ this.fetchedPageSize = results.getAvailableWithoutFetching();
this.next = null;
if (query.paging()) {
@@ -60,20 +61,20 @@ public CassandraEntryIterator(ResultSet results, Query query,
this.expected = PageState.fromString(query.page()).offset();
this.skipPageOffset(query.page());
// Check the number of available rows
- E.checkState(this.fetchdPageSize <= query.limit(),
+ E.checkState(this.fetchedPageSize <= query.limit(),
"Unexpected fetched page size: %s",
- this.fetchdPageSize);
+ this.fetchedPageSize);
if (results.isFullyFetched()) {
/*
* All results fetched
* NOTE: it may be enough or not enough for the entire page
*/
- this.expected = this.fetchdPageSize;
+ this.expected = this.fetchedPageSize;
} else {
/*
- * Not fully fetched, that's fetchdPageSize == query.limit(),
+ * Not fully fetched, that's fetchedPageSize == query.limit(),
*
- * NOTE: but there may be fetchdPageSize < query.limit(), means
+ * NOTE: but there may be fetchedPageSize < query.limit(), means
* not fetched the entire page (ScyllaDB may go here #1340),
* try to fetch next page later until got the expected count.
* Can simulate by: `select.setFetchSize(total - 1)`
@@ -104,10 +105,10 @@ protected final boolean fetch() {
this.expected--;
Row row = this.rows.next();
if (this.query.paging()) {
- // Update fetchdPageSize if auto fetch the next page
+ // Update fetchedPageSize if auto fetch the next page
if (this.expected > 0L && this.availableLocal() == 0) {
if (this.rows.hasNext()) {
- this.fetchdPageSize = this.availableLocal();
+ this.fetchedPageSize = this.availableLocal();
}
}
}
@@ -167,7 +168,7 @@ protected PageState pageState() {
ExecutionInfo previous = infos.get(infos.size() - 2);
PagingState page = previous.getPagingState();
position = page.toBytes();
- offset = this.fetchdPageSize - extra;
+ offset = this.fetchedPageSize - extra;
} else {
PagingState page = this.results.getExecutionInfo().getPagingState();
if (page == null || this.expected > 0L) {
diff --git a/hugegraph-cassandra/src/main/java/org/apache/hugegraph/backend/store/cassandra/CassandraMetrics.java b/hugegraph-cassandra/src/main/java/org/apache/hugegraph/backend/store/cassandra/CassandraMetrics.java
index 4429e315d6..92e8814b04 100644
--- a/hugegraph-cassandra/src/main/java/org/apache/hugegraph/backend/store/cassandra/CassandraMetrics.java
+++ b/hugegraph-cassandra/src/main/java/org/apache/hugegraph/backend/store/cassandra/CassandraMetrics.java
@@ -24,7 +24,6 @@
import java.net.Inet4Address;
import java.net.Inet6Address;
import java.net.InetAddress;
-import java.util.Collections;
import java.util.List;
import java.util.Map;
import java.util.Set;
@@ -34,9 +33,6 @@
import org.apache.cassandra.metrics.CassandraMetricsRegistry.JmxTimerMBean;
import org.apache.cassandra.tools.NodeProbe;
import org.apache.cassandra.tools.nodetool.Compact;
-import org.apache.tinkerpop.gremlin.util.NumberHelper;
-import org.slf4j.Logger;
-
import org.apache.hugegraph.backend.store.BackendMetrics;
import org.apache.hugegraph.backend.store.BackendStoreProvider;
import org.apache.hugegraph.backend.store.BackendTable;
@@ -48,6 +44,9 @@
import org.apache.hugegraph.util.InsertionOrderUtil;
import org.apache.hugegraph.util.Log;
import org.apache.hugegraph.util.UnitUtil;
+import org.apache.tinkerpop.gremlin.util.NumberHelper;
+import org.slf4j.Logger;
+
import com.datastax.driver.core.Cluster;
import com.datastax.driver.core.Host;
import com.google.common.collect.ImmutableList;
@@ -94,7 +93,7 @@ protected String keyspace() {
}
protected List tables() {
- return Collections.unmodifiableList(this.tables);
+ return this.tables;
}
protected Map getMetricsByHost(String host) {
diff --git a/hugegraph-cassandra/src/main/java/org/apache/hugegraph/backend/store/cassandra/CassandraSessionPool.java b/hugegraph-cassandra/src/main/java/org/apache/hugegraph/backend/store/cassandra/CassandraSessionPool.java
index 1df3aadc1a..b61a16ec9d 100644
--- a/hugegraph-cassandra/src/main/java/org/apache/hugegraph/backend/store/cassandra/CassandraSessionPool.java
+++ b/hugegraph-cassandra/src/main/java/org/apache/hugegraph/backend/store/cassandra/CassandraSessionPool.java
@@ -139,7 +139,7 @@ public final boolean clusterConnected() {
/**
* The Session class is a wrapper of driver Session
- * Expect every thread hold a its own session(wrapper)
+ * Expect every thread hold its own session(wrapper)
*/
public final class Session extends AbstractBackendSession {
diff --git a/hugegraph-cassandra/src/main/java/org/apache/hugegraph/backend/store/cassandra/CassandraShard.java b/hugegraph-cassandra/src/main/java/org/apache/hugegraph/backend/store/cassandra/CassandraShard.java
index 03bb64519c..21bb932195 100644
--- a/hugegraph-cassandra/src/main/java/org/apache/hugegraph/backend/store/cassandra/CassandraShard.java
+++ b/hugegraph-cassandra/src/main/java/org/apache/hugegraph/backend/store/cassandra/CassandraShard.java
@@ -58,7 +58,8 @@
* CassandraShard is used for cassandra scanning operations.
* Each shard represents a range of tokens for a node.
* Reading data from a given shard does not cross multiple nodes.
- * Refer to AbstractColumnFamilyInputFormat from https://github.com/2013Commons/hive-cassandra/
+ * Refer to AbstractColumnFamilyInputFormat from:
+ * ...
*/
public class CassandraShard {
@@ -89,10 +90,8 @@ public CassandraShard(CassandraSessionPool.Session session,
*/
public List getSplits(long splitPartitions, long splitSize) {
// Canonical ranges, split into pieces, fetch the splits in parallel
- ExecutorService executor = new ThreadPoolExecutor(
- 0, 128, 60L,
- TimeUnit.SECONDS,
- new LinkedBlockingQueue());
+ ExecutorService executor = new ThreadPoolExecutor(0, 128, 60L, TimeUnit.SECONDS,
+ new LinkedBlockingQueue<>());
List splits = new ArrayList<>();
try {
@@ -140,10 +139,8 @@ public List getSplits(long splitPartitions, long splitSize) {
public List getSplits(String start, String end,
int splitPartitions, int splitSize) {
- ExecutorService executor = new ThreadPoolExecutor(
- 0, 128, 60L,
- TimeUnit.SECONDS,
- new LinkedBlockingQueue());
+ ExecutorService executor = new ThreadPoolExecutor(0, 128, 60L, TimeUnit.SECONDS,
+ new LinkedBlockingQueue<>());
List splits = new ArrayList<>();
try {
@@ -249,8 +246,7 @@ private static Map describeSplits(
/*
* If we have no data on this split or the size estimate is 0,
* return the full split i.e., do not sub-split
- * Assume smallest granularity of partition count available from
- * CASSANDRA-7688.
+ * Assume the smallest granularity of partition count available from CASSANDRA-7688.
*/
if (splitCount == 0) {
return ImmutableMap.of(tokenRange, (long) 128);
diff --git a/hugegraph-cassandra/src/main/java/org/apache/hugegraph/backend/store/cassandra/CassandraStore.java b/hugegraph-cassandra/src/main/java/org/apache/hugegraph/backend/store/cassandra/CassandraStore.java
index 43fe35a679..111825a19d 100644
--- a/hugegraph-cassandra/src/main/java/org/apache/hugegraph/backend/store/cassandra/CassandraStore.java
+++ b/hugegraph-cassandra/src/main/java/org/apache/hugegraph/backend/store/cassandra/CassandraStore.java
@@ -47,6 +47,7 @@
import org.apache.hugegraph.type.HugeType;
import org.apache.hugegraph.util.E;
import org.apache.hugegraph.util.Log;
+
import com.datastax.driver.core.Cluster;
import com.datastax.driver.core.KeyspaceMetadata;
import com.datastax.driver.core.Session;
@@ -55,8 +56,7 @@
import com.datastax.driver.core.exceptions.InvalidQueryException;
import com.datastax.driver.core.schemabuilder.SchemaBuilder;
-public abstract class CassandraStore
- extends AbstractBackendStore {
+public abstract class CassandraStore extends AbstractBackendStore {
private static final Logger LOG = Log.logger(CassandraStore.class);
@@ -463,7 +463,7 @@ public void rollbackTx() {
if (session.txState() != TxState.COMMITT_FAIL &&
session.txState() != TxState.CLEAN) {
- LOG.warn("Store {} expect state COMMITT_FAIL/COMMITTING/CLEAN " +
+ LOG.warn("Store {} expect state COMMIT_FAIL/COMMITTING/CLEAN " +
"than {} when rollback()", this.store, session.txState());
}
@@ -485,12 +485,8 @@ protected boolean existsKeyspace() {
}
protected boolean existsTable(String table) {
- KeyspaceMetadata keyspace = this.cluster().getMetadata()
- .getKeyspace(this.keyspace);
- if (keyspace != null && keyspace.getTable(table) != null) {
- return true;
- }
- return false;
+ KeyspaceMetadata keyspace = this.cluster().getMetadata().getKeyspace(this.keyspace);
+ return keyspace != null && keyspace.getTable(table) != null;
}
protected void initKeyspace() {
@@ -623,12 +619,10 @@ protected final void checkClusterConnected() {
"Cassandra cluster has not been connected");
}
- protected static final CassandraBackendEntry castBackendEntry(
- BackendEntry entry) {
+ protected static final CassandraBackendEntry castBackendEntry(BackendEntry entry) {
assert entry instanceof CassandraBackendEntry : entry.getClass();
if (!(entry instanceof CassandraBackendEntry)) {
- throw new BackendException(
- "Cassandra store only supports CassandraBackendEntry");
+ throw new BackendException("Cassandra store only supports CassandraBackendEntry");
}
return (CassandraBackendEntry) entry;
}
@@ -771,7 +765,7 @@ public void createOlapTable(Id id) {
public void clearOlapTable(Id id) {
String name = this.olapTableName(id);
CassandraTable table = this.table(name);
- if (table == null || !this.existsTable(table.table())) {
+ if (!this.existsTable(table.table())) {
throw new HugeException("Not exist table '%s'", name);
}
table.truncate(this.session(null));
@@ -781,7 +775,7 @@ public void clearOlapTable(Id id) {
public void removeOlapTable(Id id) {
String name = this.olapTableName(id);
CassandraTable table = this.table(name);
- if (table == null || !this.existsTable(table.table())) {
+ if (!this.existsTable(table.table())) {
throw new HugeException("Not exist table '%s'", name);
}
table.dropTable(this.session(null));
@@ -793,8 +787,7 @@ public static class CassandraSystemStore extends CassandraGraphStore {
private final CassandraTables.Meta meta;
- public CassandraSystemStore(BackendStoreProvider provider,
- String keyspace, String store) {
+ public CassandraSystemStore(BackendStoreProvider provider, String keyspace, String store) {
super(provider, keyspace, store);
this.meta = new CassandraTables.Meta();
diff --git a/hugegraph-cassandra/src/main/java/org/apache/hugegraph/backend/store/cassandra/CassandraTable.java b/hugegraph-cassandra/src/main/java/org/apache/hugegraph/backend/store/cassandra/CassandraTable.java
index 9f639ac5ef..636429bb9c 100644
--- a/hugegraph-cassandra/src/main/java/org/apache/hugegraph/backend/store/cassandra/CassandraTable.java
+++ b/hugegraph-cassandra/src/main/java/org/apache/hugegraph/backend/store/cassandra/CassandraTable.java
@@ -76,8 +76,7 @@
import com.google.common.collect.ImmutableMap;
public abstract class CassandraTable
- extends BackendTable {
+ extends BackendTable {
private static final Logger LOG = Log.logger(CassandraTable.class);
private static final int MAX_ELEMENTS_IN_CLAUSE = 65535;
@@ -252,7 +251,7 @@ protected void setPageState(Query query, List selects) {
/*
* Can't set limit here `select.limit(total)`
* due to it will cause can't get the next page-state.
- * Also can't set `select.limit(total + 1)` due to it will
+ * Also, can't set `select.limit(total + 1)` due to it will
* cause error "Paging state mismatch" when setPagingState().
*/
@@ -566,11 +565,11 @@ protected Update buildEliminate(CassandraBackendEntry.Row entry) {
for (HugeKeys key : colNames) {
/*
* NOTE: eliminate from map should just pass key,
- * if use the following statement:
+ * if we use the following statement:
* UPDATE vertices SET PROPERTIES=PROPERTIES-{'city':'"Wuhan"'}
* WHERE LABEL='person' AND PRIMARY_VALUES='josh';
* it will throw a cassandra exception:
- * Invalid map literal for properties of typefrozen>
+ * Invalid map literal for properties of type-frozen>
*/
if (!columns.containsKey(key)) {
continue;
diff --git a/hugegraph-cassandra/src/main/java/org/apache/hugegraph/backend/store/cassandra/CassandraTables.java b/hugegraph-cassandra/src/main/java/org/apache/hugegraph/backend/store/cassandra/CassandraTables.java
index 2c3a0ca999..d546bd6aa8 100644
--- a/hugegraph-cassandra/src/main/java/org/apache/hugegraph/backend/store/cassandra/CassandraTables.java
+++ b/hugegraph-cassandra/src/main/java/org/apache/hugegraph/backend/store/cassandra/CassandraTables.java
@@ -36,6 +36,7 @@
import org.apache.hugegraph.type.define.Directions;
import org.apache.hugegraph.type.define.HugeKeys;
import org.apache.hugegraph.util.E;
+
import com.datastax.driver.core.DataType;
import com.datastax.driver.core.ResultSet;
import com.datastax.driver.core.Row;
@@ -413,7 +414,7 @@ protected List idColumnValue(Id id) {
String[] idParts = EdgeId.split(id);
if (idParts.length == 1) {
// Delete edge by label
- return Arrays.asList((Object[]) idParts);
+ return Arrays.asList(idParts);
}
id = IdUtil.readString(id.asString());
edgeId = EdgeId.parse(id.asString());
@@ -453,7 +454,7 @@ public void delete(CassandraSessionPool.Session session,
return;
}
- // The only element is label
+ // The only element is labeled
this.deleteEdgesByLabel(session, entry.id());
}
@@ -482,8 +483,7 @@ protected void deleteEdgesByLabel(CassandraSessionPool.Session session,
// Delete edges
long count = 0L;
- for (Iterator it = rs.iterator(); it.hasNext();) {
- Row row = it.next();
+ for (Row row : rs) {
Object ownerVertex = row.getObject(OWNER_VERTEX);
Object sortValues = row.getObject(SORT_VALUES);
Object otherVertex = row.getObject(OTHER_VERTEX);
@@ -643,8 +643,8 @@ public void delete(CassandraSessionPool.Session session,
final String FIELD_VALUES = formatKey(HugeKeys.FIELD_VALUES);
long count = 0L;
- for (Iterator it = rs.iterator(); it.hasNext();) {
- fieldValues = it.next().get(FIELD_VALUES, String.class);
+ for (Row r : rs) {
+ fieldValues = r.get(FIELD_VALUES, String.class);
Delete delete = QueryBuilder.delete().from(this.table());
delete.where(formatEQ(HugeKeys.INDEX_LABEL_ID, indexLabel));
delete.where(formatEQ(HugeKeys.FIELD_VALUES, fieldValues));
@@ -660,8 +660,7 @@ public void delete(CassandraSessionPool.Session session,
@Override
public void insert(CassandraSessionPool.Session session,
CassandraBackendEntry.Row entry) {
- throw new BackendException(
- "SecondaryIndex insertion is not supported.");
+ throw new BackendException("SecondaryIndex insertion is not supported.");
}
@Override
@@ -691,8 +690,7 @@ public SearchIndex(String store) {
@Override
public void insert(CassandraSessionPool.Session session,
CassandraBackendEntry.Row entry) {
- throw new BackendException(
- "SearchIndex insertion is not supported.");
+ throw new BackendException("SearchIndex insertion is not supported.");
}
}
@@ -710,8 +708,7 @@ public UniqueIndex(String store) {
@Override
public void insert(CassandraSessionPool.Session session,
CassandraBackendEntry.Row entry) {
- throw new BackendException(
- "UniqueIndex insertion is not supported.");
+ throw new BackendException("UniqueIndex insertion is not supported.");
}
}
@@ -764,8 +761,8 @@ public void delete(CassandraSessionPool.Session session,
Long indexLabel = entry.column(HugeKeys.INDEX_LABEL_ID);
if (indexLabel == null) {
- throw new BackendException("Range index deletion " +
- "needs INDEX_LABEL_ID, but not provided.");
+ throw new BackendException("Range index deletion needs INDEX_LABEL_ID, " +
+ "but not provided.");
}
Delete delete = QueryBuilder.delete().from(this.table());
@@ -776,8 +773,7 @@ public void delete(CassandraSessionPool.Session session,
@Override
public void insert(CassandraSessionPool.Session session,
CassandraBackendEntry.Row entry) {
- throw new BackendException(
- "RangeIndex insertion is not supported.");
+ throw new BackendException("RangeIndex insertion is not supported.");
}
@Override
@@ -869,8 +865,7 @@ protected DataType fieldValuesType() {
@Override
public void insert(CassandraSessionPool.Session session,
CassandraBackendEntry.Row entry) {
- throw new BackendException(
- "ShardIndex insertion is not supported.");
+ throw new BackendException("ShardIndex insertion is not supported.");
}
}
diff --git a/hugegraph-core/src/main/java/org/apache/hugegraph/version/CoreVersion.java b/hugegraph-core/src/main/java/org/apache/hugegraph/version/CoreVersion.java
index e47fd8fc78..603bf618bc 100644
--- a/hugegraph-core/src/main/java/org/apache/hugegraph/version/CoreVersion.java
+++ b/hugegraph-core/src/main/java/org/apache/hugegraph/version/CoreVersion.java
@@ -34,14 +34,12 @@ public class CoreVersion {
public static final String DEFAULT_VERSION = "1.0.0";
// The second parameter of Version.of() is for IDE running without JAR
- public static final Version VERSION = Version.of(CoreVersion.class,
- DEFAULT_VERSION);
+ public static final Version VERSION = Version.of(CoreVersion.class, DEFAULT_VERSION);
public static final String GREMLIN_VERSION = "3.4.3";
public static void check() {
// Check version of hugegraph-common
- VersionUtil.check(CommonVersion.VERSION, "2.1.0", "2.2.0",
- CommonVersion.NAME);
+ VersionUtil.check(CommonVersion.VERSION, "2.1.0", "2.2.0", CommonVersion.NAME);
}
}
diff --git a/hugegraph-dist/src/assembly/static/bin/hugegraph b/hugegraph-dist/src/assembly/static/bin/hugegraph
index cc566c3063..f39a15c25a 100644
--- a/hugegraph-dist/src/assembly/static/bin/hugegraph
+++ b/hugegraph-dist/src/assembly/static/bin/hugegraph
@@ -114,7 +114,7 @@ status() {
# Get status of HugeGraphServer to ensure it is alive
get_status() {
- HTTP_CODE=`curl -I -s -w "%{http_code}" -o /dev/null $DETECT_URL`
+ HTTP_CODE=$(curl -I -s -w "%{http_code}" -o /dev/null $DETECT_URL)
if [ $HTTP_CODE = 200 ]; then
return 0
else
diff --git a/pom.xml b/pom.xml
index a51ef9b0c4..f70abdddcc 100644
--- a/pom.xml
+++ b/pom.xml
@@ -6,19 +6,17 @@
hugegraph
${revision}
pom
-
- 3.3.9
-
+
hugegraph
- https://github.com/hugegraph/hugegraph
+ https://github.com/apache/hugegraph
hugegraph is a fast-speed, highly-scalable, transactional graph database developed by baidu
- org.sonatype.oss
- oss-parent
- 7
+ org.apache
+ apache
+ 23
2017
@@ -30,63 +28,16 @@
+
+ 3.5.0
+
+
- https://github.com/hugegraph/hugegraph
- https://github.com/hugegraph/hugegraph
- https://github.com/hugegraph/hugegraph
+ https://github.com/apache/hugegraph
+ https://github.com/apache/hugegraph
+ https://github.com/apache/hugegraph
-
-
- lizhangmei
- javaloveme@gmail.com
-
-
- zhoney
- zhangyi89817@126.com
-
-
- liningrui
- liningrui@vip.qq.com
-
-
- wangjiankui
- wangjiankui1989@163.com
-
-
- lizhigang
- albert_liang@126.com
-
-
- huanghaiping
- 954872405@qq.com
-
-
- jishilei
- littlestonelover@gmail.com
-
-
- zhanghuimin
- 283157054@qq.com
-
-
- liunanke
- lnkustc@126.com
-
-
- liujie
- liujie23@unknown
-
-
- houzhizhen
- houzhizhen_101@163.com
-
-
- zhangsuochao
- mysuochao@163.com
-
-
-
1.0.0
UTF-8
@@ -109,11 +60,11 @@
bash
3.1.2
8.45
- 1.0.0
- 1.0.0
+ 1.0.0
1.47.0
3.21.7
+
hugegraph-core
hugegraph-api
@@ -131,16 +82,16 @@
-
+
org.apache.hugegraph
hugegraph-rpc
- ${hugegraph-rpc.version}
+ ${hugegraph-commons.version}
org.apache.hugegraph
hugegraph-common
- ${hugegraph-common.version}
+ ${hugegraph-commons.version}
@@ -608,7 +559,6 @@
org.apache.maven.plugins
maven-source-plugin
- 2.2.1
attach-sources
@@ -621,7 +571,6 @@
org.apache.maven.plugins
maven-javadoc-plugin
- 2.9.1
attach-javadocs
@@ -639,7 +588,6 @@
org.apache.maven.plugins
maven-gpg-plugin
- 1.5
sign-artifacts