Skip to content

Commit ae56746

Browse files
committed
Fix doc (replace T with V)
1 parent c2be415 commit ae56746

File tree

3 files changed

+7
-7
lines changed

3 files changed

+7
-7
lines changed

core/src/main/scala/org/apache/spark/api/java/JavaPairRDD.scala

Lines changed: 3 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -231,7 +231,7 @@ class JavaPairRDD[K, V](val rdd: RDD[(K, V)])
231231
/**
232232
* Aggregate the values of each key, using given combine functions and a neutral "zero value".
233233
* This function can return a different result type, U, than the type of the values in this RDD,
234-
* V. Thus, we need one operation for merging a T into a U and one operation for merging two U's,
234+
* V. Thus, we need one operation for merging a V into a U and one operation for merging two U's,
235235
* as in scala.TraversableOnce. The former operation is used for merging values within a partition,
236236
* and the latter is used for merging values between partitions. To avoid memory allocation, both
237237
* of these functions are allowed to modify and return their first argument instead of creating a
@@ -246,7 +246,7 @@ class JavaPairRDD[K, V](val rdd: RDD[(K, V)])
246246
/**
247247
* Aggregate the values of each key, using given combine functions and a neutral "zero value".
248248
* This function can return a different result type, U, than the type of the values in this RDD,
249-
* V. Thus, we need one operation for merging a T into a U and one operation for merging two U's,
249+
* V. Thus, we need one operation for merging a V into a U and one operation for merging two U's,
250250
* as in scala.TraversableOnce. The former operation is used for merging values within a partition,
251251
* and the latter is used for merging values between partitions. To avoid memory allocation, both
252252
* of these functions are allowed to modify and return their first argument instead of creating a
@@ -261,7 +261,7 @@ class JavaPairRDD[K, V](val rdd: RDD[(K, V)])
261261
/**
262262
* Aggregate the values of each key, using given combine functions and a neutral "zero value".
263263
* This function can return a different result type, U, than the type of the values in this RDD,
264-
* V. Thus, we need one operation for merging a T into a U and one operation for merging two U's.
264+
* V. Thus, we need one operation for merging a V into a U and one operation for merging two U's.
265265
* The former operation is used for merging values within a partition, and the latter is used for
266266
* merging values between partitions. To avoid memory allocation, both of these functions are
267267
* allowed to modify and return their first argument instead of creating a new U.

core/src/main/scala/org/apache/spark/rdd/PairRDDFunctions.scala

Lines changed: 3 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -121,7 +121,7 @@ class PairRDDFunctions[K, V](self: RDD[(K, V)])
121121
/**
122122
* Aggregate the values of each key, using given combine functions and a neutral "zero value".
123123
* This function can return a different result type, U, than the type of the values in this RDD,
124-
* V. Thus, we need one operation for merging a T into a U and one operation for merging two U's,
124+
* V. Thus, we need one operation for merging a V into a U and one operation for merging two U's,
125125
* as in scala.TraversableOnce. The former operation is used for merging values within a partition,
126126
* and the latter is used for merging values between partitions. To avoid memory allocation, both
127127
* of these functions are allowed to modify and return their first argument instead of creating a
@@ -143,7 +143,7 @@ class PairRDDFunctions[K, V](self: RDD[(K, V)])
143143
/**
144144
* Aggregate the values of each key, using given combine functions and a neutral "zero value".
145145
* This function can return a different result type, U, than the type of the values in this RDD,
146-
* V. Thus, we need one operation for merging a T into a U and one operation for merging two U's,
146+
* V. Thus, we need one operation for merging a V into a U and one operation for merging two U's,
147147
* as in scala.TraversableOnce. The former operation is used for merging values within a partition,
148148
* and the latter is used for merging values between partitions. To avoid memory allocation, both
149149
* of these functions are allowed to modify and return their first argument instead of creating a
@@ -157,7 +157,7 @@ class PairRDDFunctions[K, V](self: RDD[(K, V)])
157157
/**
158158
* Aggregate the values of each key, using given combine functions and a neutral "zero value".
159159
* This function can return a different result type, U, than the type of the values in this RDD,
160-
* V. Thus, we need one operation for merging a T into a U and one operation for merging two U's,
160+
* V. Thus, we need one operation for merging a V into a U and one operation for merging two U's,
161161
* as in scala.TraversableOnce. The former operation is used for merging values within a partition,
162162
* and the latter is used for merging values between partitions. To avoid memory allocation, both
163163
* of these functions are allowed to modify and return their first argument instead of creating a

python/pyspark/rdd.py

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -1183,7 +1183,7 @@ def aggregateByKey(self, zeroValue, seqFunc, combFunc, numPartitions=None):
11831183
"""
11841184
Aggregate the values of each key, using given combine functions and a neutral "zero value".
11851185
This function can return a different result type, U, than the type of the values in this RDD,
1186-
V. Thus, we need one operation for merging a T into a U and one operation for merging two U's,
1186+
V. Thus, we need one operation for merging a V into a U and one operation for merging two U's,
11871187
The former operation is used for merging values within a partition, and the latter is used
11881188
for merging values between partitions. To avoid memory allocation, both of these functions are
11891189
allowed to modify and return their first argument instead of creating a new U.

0 commit comments

Comments
 (0)