introduce tinkerpop pipes for activity stream processing