Jython AbstractPipeClosure Example

gistfile1.py

# Jython AbstractPipeClosure Example
# by James Thornton, http://jamesthornton.com

from com.tinkerpop.pipes.util import FluentPipeline
from com.tinkerpop.pipes import AbstractPipeClosure
from com.tinkerpop.blueprints.pgm.impls.tg import TinkerGraphFactory

class StartsWithJ(AbstractPipeClosure):

    def compute(self,objects):
        return objects[0].startswith("j")
     

starts_with_j = StartsWithJ()
pipe = FluentPipeline()
g = TinkerGraphFactory.createTinkerGraph()

results =  pipe.start(g.getVertex(1)).out("knows").property("name").filter(starts_with_j).back(2).out("created")
    
for vertex in results:
    print vertex