Skip to content
Draft
Show file tree
Hide file tree
Changes from all commits
Commits
File filter

Filter by extension

Filter by extension


Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
2 changes: 1 addition & 1 deletion docker/configs/server1-conf/gremlin-driver-settings.yaml
Original file line number Diff line number Diff line change
Expand Up @@ -17,7 +17,7 @@
hosts: [localhost]
port: 8181
serializer: {
className: org.apache.tinkerpop.gremlin.driver.ser.GraphSONMessageSerializerV1d0,
className: org.apache.tinkerpop.gremlin.util.ser.GraphSONMessageSerializerV1,
config: {
serializeResultToString: false,
ioRegistries: [org.apache.hugegraph.io.HugeGraphIoRegistry]
Expand Down
8 changes: 4 additions & 4 deletions docker/configs/server1-conf/gremlin-server.yaml
Original file line number Diff line number Diff line change
Expand Up @@ -82,25 +82,25 @@ scriptEngines: {
}
}
serializers:
- {className: org.apache.tinkerpop.gremlin.driver.ser.GraphBinaryMessageSerializerV1,
- {className: org.apache.tinkerpop.gremlin.util.ser.GraphBinaryMessageSerializerV1,
config: {
serializeResultToString: false,
ioRegistries: [org.apache.hugegraph.io.HugeGraphIoRegistry]
}
}
- {className: org.apache.tinkerpop.gremlin.driver.ser.GraphSONMessageSerializerV1d0,
- {className: org.apache.tinkerpop.gremlin.util.ser.GraphSONMessageSerializerV1,
config: {
serializeResultToString: false,
ioRegistries: [org.apache.hugegraph.io.HugeGraphIoRegistry]
}
}
- {className: org.apache.tinkerpop.gremlin.driver.ser.GraphSONMessageSerializerV2d0,
- {className: org.apache.tinkerpop.gremlin.util.ser.GraphSONMessageSerializerV2,
config: {
serializeResultToString: false,
ioRegistries: [org.apache.hugegraph.io.HugeGraphIoRegistry]
}
}
- {className: org.apache.tinkerpop.gremlin.driver.ser.GraphSONMessageSerializerV3d0,
- {className: org.apache.tinkerpop.gremlin.util.ser.GraphSONMessageSerializerV3,
config: {
serializeResultToString: false,
ioRegistries: [org.apache.hugegraph.io.HugeGraphIoRegistry]
Expand Down
2 changes: 1 addition & 1 deletion docker/configs/server1-conf/remote-objects.yaml
Original file line number Diff line number Diff line change
Expand Up @@ -17,7 +17,7 @@
hosts: [localhost]
port: 8181
serializer: {
className: org.apache.tinkerpop.gremlin.driver.ser.GraphSONMessageSerializerV1d0,
className: org.apache.tinkerpop.gremlin.util.ser.GraphSONMessageSerializerV1,
config: {
serializeResultToString: false,
# The duplication of HugeGraphIoRegistry is meant to fix a bug in the
Expand Down
2 changes: 1 addition & 1 deletion docker/configs/server1-conf/remote.yaml
Original file line number Diff line number Diff line change
Expand Up @@ -17,7 +17,7 @@
hosts: [localhost]
port: 8181
serializer: {
className: org.apache.tinkerpop.gremlin.driver.ser.GraphSONMessageSerializerV1d0,
className: org.apache.tinkerpop.gremlin.util.ser.GraphSONMessageSerializerV1,
config: {
serializeResultToString: false,
ioRegistries: [org.apache.hugegraph.io.HugeGraphIoRegistry]
Expand Down
2 changes: 1 addition & 1 deletion docker/configs/server2-conf/gremlin-driver-settings.yaml
Original file line number Diff line number Diff line change
Expand Up @@ -17,7 +17,7 @@
hosts: [localhost]
port: 8182
serializer: {
className: org.apache.tinkerpop.gremlin.driver.ser.GraphSONMessageSerializerV1d0,
className: org.apache.tinkerpop.gremlin.util.ser.GraphSONMessageSerializerV1,
config: {
serializeResultToString: false,
ioRegistries: [org.apache.hugegraph.io.HugeGraphIoRegistry]
Expand Down
8 changes: 4 additions & 4 deletions docker/configs/server2-conf/gremlin-server.yaml
Original file line number Diff line number Diff line change
Expand Up @@ -82,25 +82,25 @@ scriptEngines: {
}
}
serializers:
- {className: org.apache.tinkerpop.gremlin.driver.ser.GraphBinaryMessageSerializerV1,
- {className: org.apache.tinkerpop.gremlin.util.ser.GraphBinaryMessageSerializerV1,
config: {
serializeResultToString: false,
ioRegistries: [org.apache.hugegraph.io.HugeGraphIoRegistry]
}
}
- {className: org.apache.tinkerpop.gremlin.driver.ser.GraphSONMessageSerializerV1d0,
- {className: org.apache.tinkerpop.gremlin.util.ser.GraphSONMessageSerializerV1,
config: {
serializeResultToString: false,
ioRegistries: [org.apache.hugegraph.io.HugeGraphIoRegistry]
}
}
- {className: org.apache.tinkerpop.gremlin.driver.ser.GraphSONMessageSerializerV2d0,
- {className: org.apache.tinkerpop.gremlin.util.ser.GraphSONMessageSerializerV2,
config: {
serializeResultToString: false,
ioRegistries: [org.apache.hugegraph.io.HugeGraphIoRegistry]
}
}
- {className: org.apache.tinkerpop.gremlin.driver.ser.GraphSONMessageSerializerV3d0,
- {className: org.apache.tinkerpop.gremlin.util.ser.GraphSONMessageSerializerV3,
config: {
serializeResultToString: false,
ioRegistries: [org.apache.hugegraph.io.HugeGraphIoRegistry]
Expand Down
2 changes: 1 addition & 1 deletion docker/configs/server2-conf/remote-objects.yaml
Original file line number Diff line number Diff line change
Expand Up @@ -17,7 +17,7 @@
hosts: [localhost]
port: 8182
serializer: {
className: org.apache.tinkerpop.gremlin.driver.ser.GraphSONMessageSerializerV1d0,
className: org.apache.tinkerpop.gremlin.util.ser.GraphSONMessageSerializerV1,
config: {
serializeResultToString: false,
# The duplication of HugeGraphIoRegistry is meant to fix a bug in the
Expand Down
2 changes: 1 addition & 1 deletion docker/configs/server2-conf/remote.yaml
Original file line number Diff line number Diff line change
Expand Up @@ -17,7 +17,7 @@
hosts: [localhost]
port: 8182
serializer: {
className: org.apache.tinkerpop.gremlin.driver.ser.GraphSONMessageSerializerV1d0,
className: org.apache.tinkerpop.gremlin.util.ser.GraphSONMessageSerializerV1,
config: {
serializeResultToString: false,
ioRegistries: [org.apache.hugegraph.io.HugeGraphIoRegistry]
Expand Down
2 changes: 1 addition & 1 deletion docker/configs/server3-conf/gremlin-driver-settings.yaml
Original file line number Diff line number Diff line change
Expand Up @@ -17,7 +17,7 @@
hosts: [localhost]
port: 8183
serializer: {
className: org.apache.tinkerpop.gremlin.driver.ser.GraphSONMessageSerializerV1d0,
className: org.apache.tinkerpop.gremlin.util.ser.GraphSONMessageSerializerV1,
config: {
serializeResultToString: false,
ioRegistries: [org.apache.hugegraph.io.HugeGraphIoRegistry]
Expand Down
8 changes: 4 additions & 4 deletions docker/configs/server3-conf/gremlin-server.yaml
Original file line number Diff line number Diff line change
Expand Up @@ -82,25 +82,25 @@ scriptEngines: {
}
}
serializers:
- {className: org.apache.tinkerpop.gremlin.driver.ser.GraphBinaryMessageSerializerV1,
- {className: org.apache.tinkerpop.gremlin.util.ser.GraphBinaryMessageSerializerV1,
config: {
serializeResultToString: false,
ioRegistries: [org.apache.hugegraph.io.HugeGraphIoRegistry]
}
}
- {className: org.apache.tinkerpop.gremlin.driver.ser.GraphSONMessageSerializerV1d0,
- {className: org.apache.tinkerpop.gremlin.util.ser.GraphSONMessageSerializerV1,
config: {
serializeResultToString: false,
ioRegistries: [org.apache.hugegraph.io.HugeGraphIoRegistry]
}
}
- {className: org.apache.tinkerpop.gremlin.driver.ser.GraphSONMessageSerializerV2d0,
- {className: org.apache.tinkerpop.gremlin.util.ser.GraphSONMessageSerializerV2,
config: {
serializeResultToString: false,
ioRegistries: [org.apache.hugegraph.io.HugeGraphIoRegistry]
}
}
- {className: org.apache.tinkerpop.gremlin.driver.ser.GraphSONMessageSerializerV3d0,
- {className: org.apache.tinkerpop.gremlin.util.ser.GraphSONMessageSerializerV3,
config: {
serializeResultToString: false,
ioRegistries: [org.apache.hugegraph.io.HugeGraphIoRegistry]
Expand Down
2 changes: 1 addition & 1 deletion docker/configs/server3-conf/remote-objects.yaml
Original file line number Diff line number Diff line change
Expand Up @@ -17,7 +17,7 @@
hosts: [localhost]
port: 8183
serializer: {
className: org.apache.tinkerpop.gremlin.driver.ser.GraphSONMessageSerializerV1d0,
className: org.apache.tinkerpop.gremlin.util.ser.GraphSONMessageSerializerV1,
config: {
serializeResultToString: false,
# The duplication of HugeGraphIoRegistry is meant to fix a bug in the
Expand Down
2 changes: 1 addition & 1 deletion docker/configs/server3-conf/remote.yaml
Original file line number Diff line number Diff line change
Expand Up @@ -17,7 +17,7 @@
hosts: [localhost]
port: 8183
serializer: {
className: org.apache.tinkerpop.gremlin.driver.ser.GraphSONMessageSerializerV1d0,
className: org.apache.tinkerpop.gremlin.util.ser.GraphSONMessageSerializerV1,
config: {
serializeResultToString: false,
ioRegistries: [org.apache.hugegraph.io.HugeGraphIoRegistry]
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -35,8 +35,8 @@
import org.apache.tinkerpop.gremlin.driver.Cluster;
import org.apache.tinkerpop.gremlin.driver.Result;
import org.apache.tinkerpop.gremlin.driver.ResultSet;
import org.apache.tinkerpop.gremlin.driver.Tokens;
import org.apache.tinkerpop.gremlin.driver.message.RequestMessage;
import org.apache.tinkerpop.gremlin.util.Tokens;
import org.apache.tinkerpop.gremlin.util.message.RequestMessage;
import org.slf4j.Logger;

@ThreadSafe
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -19,7 +19,7 @@
import static java.util.Collections.emptyMap;
import static java.util.Collections.singletonList;
import static java.util.Optional.empty;
import static org.apache.tinkerpop.gremlin.driver.message.ResponseStatusCode.SERVER_ERROR;
import static org.apache.tinkerpop.gremlin.util.message.ResponseStatusCode.SERVER_ERROR;
import static org.opencypher.gremlin.translation.StatementOption.EXPLAIN;
import static org.slf4j.LoggerFactory.getLogger;

Expand All @@ -33,10 +33,10 @@
import java.util.concurrent.FutureTask;
import java.util.concurrent.TimeUnit;

import org.apache.tinkerpop.gremlin.driver.Tokens;
import org.apache.tinkerpop.gremlin.driver.message.RequestMessage;
import org.apache.tinkerpop.gremlin.driver.message.ResponseMessage;
import org.apache.tinkerpop.gremlin.driver.message.ResponseStatusCode;
import org.apache.tinkerpop.gremlin.util.Tokens;
import org.apache.tinkerpop.gremlin.util.message.RequestMessage;
import org.apache.tinkerpop.gremlin.util.message.ResponseMessage;
import org.apache.tinkerpop.gremlin.util.message.ResponseStatusCode;
import org.apache.tinkerpop.gremlin.process.traversal.P;
import org.apache.tinkerpop.gremlin.process.traversal.TraversalSource;
import org.apache.tinkerpop.gremlin.process.traversal.dsl.graph.DefaultGraphTraversal;
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -25,10 +25,10 @@
import java.util.Objects;
import java.util.Set;
import java.util.function.BiFunction;
import java.util.function.BiPredicate;

import org.apache.commons.lang.ArrayUtils;
import org.apache.hugegraph.backend.id.Id;
import org.apache.tinkerpop.gremlin.process.traversal.PBiPredicate;
import org.apache.hugegraph.backend.store.Shard;
import org.apache.hugegraph.structure.HugeElement;
import org.apache.hugegraph.structure.HugeProperty;
Expand All @@ -51,7 +51,7 @@ public enum ConditionType {
NOT
}

public enum RelationType implements BiPredicate<Object, Object> {
public enum RelationType implements PBiPredicate<Object, Object> {

EQ("==", RelationType::equals),

Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -17,16 +17,15 @@

package org.apache.hugegraph.traversal.optimize;

import java.util.function.BiPredicate;

import org.apache.hugegraph.backend.query.Condition;
import org.apache.tinkerpop.gremlin.process.traversal.P;
import org.apache.tinkerpop.gremlin.process.traversal.PBiPredicate;

public class ConditionP extends P<Object> {

private static final long serialVersionUID = 9094970577400072902L;

private ConditionP(final BiPredicate<Object, Object> predicate,
private ConditionP(final PBiPredicate<Object, Object> predicate,
Object value) {
super(predicate, value);
}
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -24,7 +24,6 @@
import java.util.List;
import java.util.Map;
import java.util.Optional;
import java.util.function.BiPredicate;
import java.util.function.Function;
import java.util.regex.Matcher;
import java.util.regex.Pattern;
Expand Down Expand Up @@ -56,6 +55,7 @@
import org.apache.tinkerpop.gremlin.process.traversal.Contains;
import org.apache.tinkerpop.gremlin.process.traversal.Order;
import org.apache.tinkerpop.gremlin.process.traversal.P;
import org.apache.tinkerpop.gremlin.process.traversal.PBiPredicate;
import org.apache.tinkerpop.gremlin.process.traversal.Step;
import org.apache.tinkerpop.gremlin.process.traversal.Traversal;
import org.apache.tinkerpop.gremlin.process.traversal.dsl.graph.GraphTraversal;
Expand Down Expand Up @@ -350,7 +350,7 @@ public static void fillConditionQuery(ConditionQuery query,
public static Condition convHas2Condition(HasContainer has, HugeType type, HugeGraph graph) {
P<?> p = has.getPredicate();
E.checkArgument(p != null, "The predicate of has(%s) is null", has);
BiPredicate<?, ?> bp = p.getBiPredicate();
PBiPredicate<?, ?> bp = p.getBiPredicate();
Condition condition;
if (keyForContainsKeyOrValue(has.getKey())) {
condition = convContains2Relation(graph, has);
Expand Down Expand Up @@ -423,7 +423,7 @@ private static Condition.Relation convCompare2Relation(HugeGraph graph,
HugeType type,
HasContainer has) {
assert type.isGraph();
BiPredicate<?, ?> bp = has.getPredicate().getBiPredicate();
PBiPredicate<?, ?> bp = has.getPredicate().getBiPredicate();
assert bp instanceof Compare;

return isSysProp(has.getKey()) ?
Expand All @@ -434,7 +434,7 @@ private static Condition.Relation convCompare2Relation(HugeGraph graph,
private static Condition.Relation convCompare2SyspropRelation(HugeGraph graph,
HugeType type,
HasContainer has) {
BiPredicate<?, ?> bp = has.getPredicate().getBiPredicate();
PBiPredicate<?, ?> bp = has.getPredicate().getBiPredicate();
assert bp instanceof Compare;

HugeKeys key = token2HugeKey(has.getKey());
Expand Down Expand Up @@ -462,7 +462,7 @@ private static Condition.Relation convCompare2SyspropRelation(HugeGraph graph,
private static Condition.Relation convCompare2UserpropRelation(HugeGraph graph,
HugeType type,
HasContainer has) {
BiPredicate<?, ?> bp = has.getPredicate().getBiPredicate();
PBiPredicate<?, ?> bp = has.getPredicate().getBiPredicate();
assert bp instanceof Compare;

String key = has.getKey();
Expand Down Expand Up @@ -492,7 +492,7 @@ private static Condition convRelationType2Relation(HugeGraph graph,
HugeType type,
HasContainer has) {
assert type.isGraph();
BiPredicate<?, ?> bp = has.getPredicate().getBiPredicate();
PBiPredicate<?, ?> bp = has.getPredicate().getBiPredicate();
assert bp instanceof Condition.RelationType;

String key = has.getKey();
Expand All @@ -505,7 +505,7 @@ private static Condition convRelationType2Relation(HugeGraph graph,
public static Condition convIn2Relation(HugeGraph graph,
HugeType type,
HasContainer has) {
BiPredicate<?, ?> bp = has.getPredicate().getBiPredicate();
PBiPredicate<?, ?> bp = has.getPredicate().getBiPredicate();
assert bp instanceof Contains;
Collection<?> values = (Collection<?>) has.getValue();

Expand Down Expand Up @@ -548,7 +548,7 @@ public static Condition convIn2Relation(HugeGraph graph,
public static Condition convContains2Relation(HugeGraph graph,
HasContainer has) {
// Convert contains-key or contains-value
BiPredicate<?, ?> bp = has.getPredicate().getBiPredicate();
PBiPredicate<?, ?> bp = has.getPredicate().getBiPredicate();
E.checkArgument(bp == Compare.eq, "CONTAINS query with relation " +
"'%s' is not supported", bp);

Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -31,7 +31,7 @@ public class CoreVersion {
/**
* Update it when the gremlin version changed, search "tinkerpop.version" in pom
*/
public static final String GREMLIN_VERSION = "3.5.1";
public static final String GREMLIN_VERSION = "3.7.2";

static {
// Check versions of the dependency packages
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -17,7 +17,7 @@
hosts: [localhost]
port: 8182
serializer: {
className: org.apache.tinkerpop.gremlin.driver.ser.GraphSONMessageSerializerV1d0,
className: org.apache.tinkerpop.gremlin.util.ser.GraphSONMessageSerializerV1,
config: {
serializeResultToString: false,
ioRegistries: [org.apache.hugegraph.io.HugeGraphIoRegistry]
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -82,25 +82,25 @@ scriptEngines: {
}
}
serializers:
- {className: org.apache.tinkerpop.gremlin.driver.ser.GraphBinaryMessageSerializerV1,
- {className: org.apache.tinkerpop.gremlin.util.ser.GraphBinaryMessageSerializerV1,
config: {
serializeResultToString: false,
ioRegistries: [org.apache.hugegraph.io.HugeGraphIoRegistry]
}
}
- {className: org.apache.tinkerpop.gremlin.driver.ser.GraphSONMessageSerializerV1d0,
- {className: org.apache.tinkerpop.gremlin.util.ser.GraphSONMessageSerializerV1,
config: {
serializeResultToString: false,
ioRegistries: [org.apache.hugegraph.io.HugeGraphIoRegistry]
}
}
- {className: org.apache.tinkerpop.gremlin.driver.ser.GraphSONMessageSerializerV2d0,
- {className: org.apache.tinkerpop.gremlin.util.ser.GraphSONMessageSerializerV2,
config: {
serializeResultToString: false,
ioRegistries: [org.apache.hugegraph.io.HugeGraphIoRegistry]
}
}
- {className: org.apache.tinkerpop.gremlin.driver.ser.GraphSONMessageSerializerV3d0,
- {className: org.apache.tinkerpop.gremlin.util.ser.GraphSONMessageSerializerV3,
config: {
serializeResultToString: false,
ioRegistries: [org.apache.hugegraph.io.HugeGraphIoRegistry]
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -17,7 +17,7 @@
hosts: [localhost]
port: 8182
serializer: {
className: org.apache.tinkerpop.gremlin.driver.ser.GraphSONMessageSerializerV1d0,
className: org.apache.tinkerpop.gremlin.util.ser.GraphSONMessageSerializerV1,
config: {
serializeResultToString: false,
# The duplication of HugeGraphIoRegistry is meant to fix a bug in the
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -17,7 +17,7 @@
hosts: [localhost]
port: 8182
serializer: {
className: org.apache.tinkerpop.gremlin.driver.ser.GraphSONMessageSerializerV1d0,
className: org.apache.tinkerpop.gremlin.util.ser.GraphSONMessageSerializerV1,
config: {
serializeResultToString: false,
ioRegistries: [org.apache.hugegraph.io.HugeGraphIoRegistry]
Expand Down
Loading
Loading