[FLINK-1110] Add createCollectionEnvironment for Scala
[FLINK-1110] Implement collection-based execution for coGroup