Turn RDF graphs into JSON trees.

build.sbt

resolvers += "Twitter Repo" at "http://maven.twttr.com"

libraryDependencies ++= Seq(
  "com.twitter" %% "json" % "2.1.6",
  "org.scardf" % "scardf" % "0.5" from "http://scardf.googlecode.com/files/scardf-0.5.jar",
  "joda-time" % "joda-time" % "1.6.1" // Used by scardf
)

Treeify.scala

import org.scardf._

object Treeify {

def localName(res:UriRef) = ".*[#/]".r.split(res.uri)(1)

def apply(start:GraphNode) = {
  val graph = start.graph

  def treeify(subject:SubjectNode, visited:Set[SubjectNode]):Map[String,Any] = Map(
    Some(subject).collect { case u:UriRef => "uri" -> u.uri }.toSeq ++ (
    graph.triplesLike(subject,UriRef,Node) collect {
      case RdfTriple(_, RDF.Type, typ:UriRef) => "type" -> localName(typ)
      case RdfTriple(_, pred, value:SubjectNode) if !visited.contains(value)=>localName(pred) -> treeify(value, visited + subject) 
      case RdfTriple(_, pred, TypedLiteral(value, datatype)) => (localName(pred), datatype match {
        case XSD.int | XSD.integer => value.toInt
        case XSD.float | XSD.double => value.toFloat
        case XSD.boolean => value.toBoolean
        case other => value
      })
      case RdfTriple(_, pred, PlainLiteral(value, _)) => localName(pred) -> value
    } ): _*
    // .groupBy(_._1).mapValues(_.map(_._2)
  )

  treeify(start.node, Set(start.node))
}

}