KeyedStream Transformations(键控流转换算子)

keyby

分流算子, 流的类型改变了

DataStream → KeyedStream

黑色去一条流，剩下的去另一条流

// 以数据的id为key分流 stream.keyBy(r => r.id) // 以case class的word字段为key分流 stream.keyBy("word")