java - Gremlin-driver 无法获得 titandb 的响应

Question

我正在尝试使用 gremlin 驱动程序通过 WebSockets 查询服务器 titan 实例。所以我有下一个依赖项:

    <dependency>
        <groupId>org.apache.tinkerpop</groupId>
        <artifactId>gremlin-driver</artifactId>
        <version>3.1.1-incubating</version>
    </dependency>

尝试使用下一个命令获取值:

       List<Result> some = client.submit("g.V().has(T.label, marketplace).has('marketplace_product_id', marketplace_product_id)", params).some(1).get();

并获取下一个异常:

 WARN  o.a.t.g.driver.MessageSerializer - Response [PooledUnsafeDirectByteBuf(ridx: 136, widx: 136, cap: 136)] could not be deserialized by org.apache.tinkerpop.gremlin.driver.ser.GryoMessageSerializerV1d0.
13:41:36.879 [gremlin-driver-loop-1] ERROR o.a.t.g.d.Handler$GremlinResponseHandler - Could not process the response
io.netty.handler.codec.DecoderException: org.apache.tinkerpop.gremlin.driver.ser.SerializationException: java.lang.IndexOutOfBoundsException: Index: 121, Size: 0

没有在网络上找到关于使用 gremlin 驱动程序的 CRUD 操作的可行示例。有人知道如何处理吗？

编辑 1:使用 titan-1.0.0-hadoop1还尝试使用驱动程序版本 3.0.1-incubating 并得到几乎相同的 IndexOutOfBoundsException。

Answer 1

试试这个:可能会有帮助

List<Result> some = null; 
some = client.submit("g.V()
                 .has(T.label,marketplace)
                 .has('marketplace_product_id', marketplace_product_id)")
             .stream()**
             .map(r -> r.get(Vertex.class))**
             .collect(Collectors.toList());