DoFnimplementation that converts an
Iterableof values into a single value. If a
CombineFninstance is used on a
PGroupedTable, the function will be applied to the output of the map stage before the data is passed to the reducer, which can improve the runtime of certain classes of jobs.
|Constructor and Description|
Copyright © 2017 The Apache Software Foundation. All rights reserved.