Modified stuff to work with tdas/spark next-gen branch. Added configs to easily switch between offloaded and non-offloaded streaming computations.