How to improve the write speed of Java connection janusgraph?


wenco...@...
 

Is it necessary to change the configuration of janusgraph?

Cluster cluster = Cluster.build()
.addContactPoints(janusGraphHosts)
.port(janusGraphPort)
.credentials(janusGraphUserName, janusGraphPassword)
.serializer(new GryoMessageSerializerV1d0(GryoMapper.build().addRegistry(JanusGraphIoRegistry.getInstance())))
.maxConnectionPoolSize(8)
.create();
return AnonymousTraversalSource.traversal().withRemote(DriverRemoteConnection.using(cluster, janusGraphSourceName));


ramosrods@...
 

I’m also trying to running theses parameters to process traversals in parallel using a thread pool. The most interesting parameters I’ve found until now are maxInProcessRequest and maxWaitForConnection. Also find this StackOverflow question helpful: https://stackoverflow.com/questions/41639616/titan-parallel-queries-concurrent-time-out-exception-at-org-apache-tinkerpop-g


hadoopmarc@...
 

This blog might be a good start for your further experiments:

https://www.experoinc.com/post/janusgraph-nuts-and-bolts-part-1-write-performance

Best wishes,   Marc