重新分区
根据提取的数据在分片之间移动记录。
public GearsBuilder<T> repartition(
gears.operations.ExtractorOperation<T> extractor)
在分片之间移动记录。提取的数据确定每个记录的新分片位置。
参数
| 名称 | 类型 | 描述 |
|---|---|---|
| 提取器 | 从每个记录中提取特定值 |
返回值
返回具有新模板类型的 GearsBuilder 对象。
示例
按值重新分区
GearsBuilder.CreateGearsBuilder(reader).
repartition(r->{
return r.getStringVal();
});