Я думаю, вам нужно JanusGraphIoRegistry
, зарегистрированное на стороне клиента:
GryoMapper.Builder builder = GryoMapper.build().
addRegistry(JanusGraphIoRegistry.getInstance());
GryoMessageSerializerV3d0 serializer = new GryoMessageSerializerV3d0(builder);
Cluster cluster = Cluster.build().
addContactPoint(host).
port(port).
serializer(serializer).
create();
Как дополнительный совет по вашему коду. Не используйте множество небольших обновлений, таких как:
public void updateVertex(Vertex v, Map<Object, Object> propertyMap) {
for(Entry<Object, Object> e : propertyMap.entrySet()) {
g.V(v).property(e.getKey(), e.getValue()).next();
}
}
и вместо этого:
public void updateVertex(Vertex v, Map<Object, Object> propertyMap) {
GraphTraversal<Vertex,Vertex> t = g.V(v);
for(Entry<Object, Object> e : propertyMap.entrySet()) {
t = t.property(e.getKey(), e.getValue());
}
t.iterate();
}
Вы также можете упростить свой код «добавить ребро»:
public Edge addEdge(String label, Vertex from, Vertex to) {
return g.V(from).addE(label).to(to).next();
}