Spark Titan

2015-06-21 Thread Madabhattula Rajesh Kumar
Hi, How to connect TItan database from Spark? Any out of the box api's available? Regards, Rajesh

Re: Spark Titan

2015-06-21 Thread Akhil Das
Have a look at http://s3.thinkaurelius.com/docs/titan/0.5.0/titan-io-format.html You could use those Input/Output formats with newAPIHadoopRDD api call. Thanks Best Regards On Sun, Jun 21, 2015 at 8:50 PM, Madabhattula Rajesh Kumar mrajaf...@gmail.com wrote: Hi, How to connect TItan

Re: Spark Titan

2015-06-21 Thread Nick Pentreath
Something like this works (or at least worked with titan 0.4 back when I was using it): val graph = sc.newAPIHadoopRDD( configuration, fClass = classOf[TitanHBaseInputFormat], kClass = classOf[NullWritable], vClass = classOf[FaunusVertex]) graph.flatMap { vertex =