using tinkerpop pipes for activity stream processing