特牛网址导航

DataStream Rebalancing partitioning_datastream().rebalance-CSDN博客

网友收藏
文章浏览阅读163次。这种类型的分区有助于均匀地分配数据。它通过循环的方式对数据进行分发。当数据倾斜时,这种类型的分区很好。 private static final long serialVersionUID = 1L; private final int[] returnArray = new int[]{-1};​ public RebalancePartitioner() ..._datastream().rebalance