major changes/refactoring

-   uses prismatic/plumbing for processing pipeline
-   splits each corpus input into several partitions (num. of CPUs) and processes them in parallel