rpuga Comments - Answer Overflow

rpuga

Explore posts from servers

•Created by rpuga on 3/23/2024 in #questions

mergeE(): increment counter on match

Thanks @Kelvin Lawrence, your solution works great! Adapting it to the example graph I was using, it looks like this:

g.mergeE([(T.label):'called', (from):p1, (to):p2]).
  option(Merge.onCreate, ['num_calls': 1]).
  option(Merge.onMatch, property('num_calls', union(values('num_calls'), constant(1)).sum()).constant([:]))

g.mergeE([(T.label):'called', (from):p1, (to):p2]).
  option(Merge.onCreate, ['num_calls': 1]).
  option(Merge.onMatch, property('num_calls', union(values('num_calls'), constant(1)).sum()).constant([:]))

16 replies

ATApache TinkerPop

•Created by dracule_redrose on 3/22/2024 in #questions

Serialization Issue

I have faced a similar issue in the past (but mostly related to gremlin-python) and @Boxuan Li suggested a solution in the JanusGraph discord server. It was something like along these lines:

private static MessageSerializer createGraphBinaryMessageSerializerV1() {
  final GraphBinaryMessageSerializerV1 serializer = new GraphBinaryMessageSerializerV1();
  final Map<String, Object> config = new HashMap<>();
  config.put(GraphBinaryMessageSerializerV1.TOKEN_IO_REGISTRIES, Collections.singletonList(JanusGraphIoRegistry.class.getName()));
  serializer.configure(config, Collections.emptyMap());
  return serializer;
}

private static MessageSerializer createGraphBinaryMessageSerializerV1() {
  final GraphBinaryMessageSerializerV1 serializer = new GraphBinaryMessageSerializerV1();
  final Map<String, Object> config = new HashMap<>();
  config.put(GraphBinaryMessageSerializerV1.TOKEN_IO_REGISTRIES, Collections.singletonList(JanusGraphIoRegistry.class.getName()));
  serializer.configure(config, Collections.emptyMap());
  return serializer;
}

and

Cluster cluster = Cluster.build()
    .addContactPoint(gremlinServer)
    .port(gremlinServerPort)
    // .serializer(new GraphBinaryMessageSerializerV1(typeSerializerRegistry))
    .serializer(createGraphBinaryMessageSerializerV1())
    .create();

Cluster cluster = Cluster.build()
    .addContactPoint(gremlinServer)
    .port(gremlinServerPort)
    // .serializer(new GraphBinaryMessageSerializerV1(typeSerializerRegistry))
    .serializer(createGraphBinaryMessageSerializerV1())
    .create();

Also, here is how he suggested to setup the serializers in the JanusGraph config file: https://github.com/Citegraph/citegraph/blob/main/backend/src/main/resources/gremlin-server-cql.yaml I hope this leads you closer to a solution.

5 replies

ATApache TinkerPop

•Created by rpuga on 3/23/2024 in #questions

mergeE(): increment counter on match

BTW, I was able to obtain the result I need with a query that looks like this:

p1 = g.addV('person').property('name', 'marko').next()
p2 = g.addV('person').property('name', 'maria').next()
g.V(p1).as("v1").
V(p2).as("v2").
coalesce(
    select("v1").outE("called").where(inV().has(id, select("v2").id())),
    addE("called").from("v1").to("v2").property("num_calls", 0)).
    as("e").
property(
    "num_calls",
    union(select("e").values("num_calls").unfold(), constant(1)).sum())

p1 = g.addV('person').property('name', 'marko').next()
p2 = g.addV('person').property('name', 'maria').next()
g.V(p1).as("v1").
V(p2).as("v2").
coalesce(
    select("v1").outE("called").where(inV().has(id, select("v2").id())),
    addE("called").from("v1").to("v2").property("num_calls", 0)).
    as("e").
property(
    "num_calls",
    union(select("e").values("num_calls").unfold(), constant(1)).sum())

but I'm wondering how something similar can be done with mergeE()

16 replies

Gaming

Programming