def loadClient(graphId: String): Client = {
val typeSerializerRegistry = TypeSerializerRegistry.build.addRegistry(JanusGraphIoRegistry.instance).create
val cluster = Cluster.build()
.addContactPoint(contactUrl)
.port(port.asInstanceOf[Int])
.serializer(new GraphBinaryMessageSerializerV1(typeSerializerRegistry))
.create()
cluster.connect()
}
def loadClient(graphId: String): Client = {
val typeSerializerRegistry = TypeSerializerRegistry.build.addRegistry(JanusGraphIoRegistry.instance).create
val cluster = Cluster.build()
.addContactPoint(contactUrl)
.port(port.asInstanceOf[Int])
.serializer(new GraphBinaryMessageSerializerV1(typeSerializerRegistry))
.create()
cluster.connect()
}