question

Hi @danielleplex_185261,

Your requests are very interesting. If I understand you well :

1. you insert a new Vertex and expect to execute some search, find existing vertices that should be related to this new comer and create edges if relevant.
2. The search is based on a text field like (address) and fuzzy search is expected
3. You would like to be able to execute this behaviour at server level using function or stored procedure.

I will provide some input based on the Java driver, hope you are using it. By the way all past `dse` driver and OSS drivers are now merged as a single one started with version 4.4, here is the doc https://docs.datastax.com/en/developer/java-driver/4.4/manual/core/dse/graph/

1. Search query

a) To enable fuzzy search with DSE graph attributes you indeed need to create Solr index.

https://docs.datastax.com/en/dse/6.7/dse-dev/datastax_enterprise/graph/using/useSearchIndexes.html

Create the Index:

schema.vertexLabel('recipe').index('search').search(). by('instructions').asText(). by('name').asString().add()

Sample gremlin:

g.V().hasLabel('author').has('name', fuzzy('James Beard', 0)).values('name')

b) The query you mentioned is not pointing the partition key, it will scan multiple nodes even if you created the index. Maybe you want to execute the query as an OLAP statement and use `a....` instead of `g.` https://docs.datastax.com/en/developer/java-driver/4.4/manual/core/dse/graph/options/#available-options

2. Implementation

This is always tricky to expect triggers in Cassandra contexts (when do you start the treatment : when first replica is updated, when you have enough for quorum, when all replica are update ?). As such you should consider to do this operation (find/connect) under the hood in your application.

I would go with a query async to insert the new Vertex. (cf `executeAsync`). You will then get a `CompletionStage<AsyncGraphResultSet>`. On the `onComplete()` method you may want to do the search (olap) and connect (oltp). Using java async capabilities like `thenCombine`, `thenApply` you might be able to do it still in your application but with an asynchronous way.

Other idea but maybe less ideal because edges will not be created immediately would be to trigger a spark job using embedded GraphFrame in DSE to execute searches and create related edges ().

Let's keep updating this post.

Cedrick