FluentPipeline Scala Example

gistfile1.scala

import com.tinkerpop.blueprints.pgm._
import com.tinkerpop.blueprints.pgm.impls.tg._
import com.tinkerpop.pipes._
import com.tinkerpop.pipes.util._
import scala.collection.JavaConversions.asScalaIterator
import java.lang.{Boolean => JBoolean}

val graph = TinkerGraphFactory.createTinkerGraph()

//Adapter from T => Boolean to PipeClosure along with an implicit conversion
class Function1PipeClosure[T](f: T => Boolean) extends AbstractPipeClosure[JBoolean, Pipe[_, _]] {
  override def compute(objects: Object*): JBoolean = f(objects(0).asInstanceOf[T])
}
implicit def fToFunction1PipeClosure[T](f: T => Boolean) = new Function1PipeClosure[T](f)

//Now we can pass a function literal instead of an AbstractPipeClosure to filter
val fp = new FluentPipeline[Vertex, String](graph getVertex 1) out "knows" property "name" filter { s: String => s startsWith "j" }
for (friendName <- fp) println(friendName)

//output is just "josh"