My personal fork of the Apache incubator-streams project