[FLINK-1249] [APIs] [compiler] Add custom partitioner for CoGroup