> 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 =>
> val edges = vertex.getEdges(Direction.OUT).filter(e => e.getLabel ==
> "...")
> edges.map { edge => (...) }
> }
>
> Note that FaunusVertex is not Serializable so you'll need to extract the
> properties (or say a JSON representation) of your vertices in the first map
> or flatMap operation (or extract your edges and properties).
>
>
> On Sun, Jun 21, 2015 at 6:57 PM, Akhil Das <ak...@sigmoidanalytics.com>
> wrote:
>
>> 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 database from Spark? Any out of the box api's
>>> available?
>>>
>>> Regards,
>>> Rajesh
>>>
>>
>>
>
