实验功能

We can re-interpret a pre-partitioned data stream as a keyed stream to avoid shuffling.

This re-interpretation functionality is exposed through :

Given a base stream, a key selector, and type information, the method creates a keyed stream from the base stream.

Java

Scala