zxnblake
commented
6 years ago I have found the issue: we should provide the "outId" and "inId" property in the edge mapping both in config file and the edge index in ES. The code will try to find the outId/inId property when forming an edge in the graph.
The following is my current config file ( I am using the embedded ES in Crate ):
{
"class": "org.unipop.elastic.ElasticSourceProvider",
"clusterName": "crate",
"addresses": "http://localhost:4200",
"vertices": [
{
"index": "vertex",
"type": "default",
"id": "@_id",
"label": "person",
"properties": {
},
"dynamicProperties": true
}
],
"edges": [
{
"index": "edge",
"type": "default",
"id": "@_id",
"label": "knows",
"properties": {
},
"dynamicProperties": {
},
"outVertex": {
"ref": true,
"id": "",
"label": "person",
"properties": {}
},
"inVertex": {
"ref": true,
"id": "",
"label": "person",
"properties": {}
}
}
]
}
seanbarzilay
HI @seanbarzilay:
I am trying the gremlin traversal with unipop-elastic. I can load data from ES into graph, and the code < graph.traversal().V("1").next().value("name") > is working well, but the following code is not working: GraphTraversal<Edge, Edge> et = graph.traversal().E("1"); Edge edges = et.next(); It always throws out the following error: java.util.NoSuchElementException org.apache.tinkerpop.gremlin.process.traversal.util.DefaultTraversal.next(DefaultTraversal.java:204) at org.unipop.elastic.tests.ConfigurationTests.upsertConfiguration(ConfigurationTests.java:40) at sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method) at sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:62) at sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43) at java.lang.reflect.Method.invoke(Method.java:498) When I debug into the code(ElasticClient.execute(action)), I can see that the query for edge with id=1 is successful, and I can see the following search result with json: {"took":1,"timed_out":false,"_shards":{"total":1,"successful":1,"failed":0},"hits":{"total":1,"max_score":1.0,"hits":[{"_index":"edge","_type":"default","_id":"1","_score":1.0,"_source":{"inVertex":{"ref":"true","id":"548","label":"person"},"label":"knows","outVertex":{"ref":"true","id":"1","label":"person"}}}]}} It seems that the edge and its inVertex and outVertex have been fetched from ES store already. Why it always failed in executing the et.next(); or et.inV().next()?