I'll let someone else have a go at question 2 :) If you're using ExecuteScript with Groovy, you don't need EvaluateJsonPath, Groovy has a JSONSlurper that works nicely (examples on my blog).
To put directly into Titan you don't need to convert the format, instead you'll want Gremlin (part of Apache Tinkerpop), point your processor's Module Path property at a folder containing the Gremlin JARs, then you can create the vertices and edges using the approach in the Titan documentation. This would make an excellent blog post, perhaps I'll give this a try myself but please feel welcome to share anything you learn along the way! If I get some spare time I'd like to write a PutGraph processor that does pretty much what we've outlined here. Regards, Matt Sent from my iPhone > On Mar 31, 2016, at 10:15 AM, idioma <corda.ila...@gmail.com> wrote: > > Matt, thank you for this this is brilliant. So, as it is I am thinking that I > would like to use the following: > > GetKafka -> EvaluateJsonPath -> ExecuteScript+Groovy Script > > My questions are two: > > 1) How do I import the Titan-compliant file into Titan? I guess I can modify > the script and load it into it. > 2) my second quest is more naive and proves the fact my background is more > on Apache Camel with very little knowledge of NiFi. In a versionControl > environment, how do you push a process flow created with NiFi that mostly > involves standard components? Do you write customized version where you set > of kafka properties, for example? > > Thanks > > > > -- > View this message in context: > http://apache-nifi-developer-list.39713.n7.nabble.com/Import-Kafka-messages-into-Titan-tp8647p8667.html > Sent from the Apache NiFi Developer List mailing list archive at Nabble.com.
