Using keyBy() operations to reduce shuffle