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()
  }

client.submit(query, statementParameters).all().get()

client.submit(query, statementParameters).all().get()