Searched refs:partiallyAggregated (Results 1 – 2 of 2) sorted by relevance
972 partiallyAggregated = self.mapPartitions(aggregatePartition)973 numPartitions = partiallyAggregated.getNumPartitions()985 partiallyAggregated = partiallyAggregated \990 return partiallyAggregated.reduce(combOp)
1137 var partiallyAggregated = mapPartitions(it => Iterator(aggregatePartition(it))) variable1138 var numPartitions = partiallyAggregated.partitions.length1147 partiallyAggregated = partiallyAggregated.mapPartitionsWithIndex {1151 partiallyAggregated.reduce(cleanCombOp)