-
Flink Java API接口介绍 - MapReduce服务 MRS
以均匀分布的形式将元素随机地进行分区。 public DataStream<T> rebalance() 基于round-robin对元素进行分区,使得每个分区负责均衡。对于存在数据倾斜的性能优化是很有用的。 public DataStream<T> rescale() 以round-robin的形式将元素分区到下游操作的子集中。
-
Flink Java API接口介绍 - MapReduce服务 MRS
以均匀分布的形式将元素随机地进行分区。 public DataStream<T> rebalance() 基于round-robin对元素进行分区,使得每个分区负责均衡。对于存在数据倾斜的性能优化是很有用的。 public DataStream<T> rescale() 以round-robin的形式将元素分区到下游操作的子集中。
-
Flink Java API接口介绍 - MapReduce服务 MRS
以均匀分布的形式将元素随机地进行分区。 public DataStream<T> rebalance() 基于round-robin对元素进行分区,使得每个分区负责均衡。对于存在数据倾斜的性能优化是很有用的。 public DataStream<T> rescale() 以round-robin的形式将元素分区到下游操作的子集中。
-
Flink Java API接口介绍 - MapReduce服务 MRS
以均匀分布的形式将元素随机地进行分区。 public DataStream<T> rebalance() 基于round-robin对元素进行分区,使得每个分区负责均衡。对于存在数据倾斜的性能优化是很有用的。 public DataStream<T> rescale() 以round-robin的形式将元素分区到下游操作的子集中。