[FLINK-1110] Implement collection-based Cross
[FLINK-1110] Implement broadcast variables for collection-based execution
[FLINK-1110] Add execution on collections for flatMap
[FLINK-1110] Add Collection-Based execution for Reduce Operators

Also fix some bugs resulting from moving stuff between packages