如何在级联中强制减速器

Question

获得一些只有化简器而不是映射器才能实现的好处。

Answer 1

在 Google 网上论坛中找到了我的答案：

使用一个GroupBy，该在执行分组时，不变将使用化简器：

previousPipe = new GroupBy(previousPipe); //this does a Group on Fields.All

减少

文件数量(另一种减少耦合的替代方法(

previousPipe = new GroupBy(previousPipe, new Fields("rand"), 
               new RandonNumGen(Fields.Args));

其中，新的 RandonNumGen(Fields.Args( 是您从Function构建的函数，用于创建一个新的 Fields("rand"(，该字段创建临时随机数(临时意味着您稍后删除该字段(。

有关更多信息，请查看此 Google 网上论坛帖子：