Toolkit for building data processing pipelines