Skip to content

Commit d6d1ccf

Browse files
combineByKey examples and notes added
1 parent ab00c74 commit d6d1ccf

File tree

1 file changed

+0
-6
lines changed

1 file changed

+0
-6
lines changed

tutorial/combine-by-key/spark-combineByKey.md

Lines changed: 0 additions & 6 deletions
Original file line numberDiff line numberDiff line change
@@ -198,10 +198,4 @@ So, you should get back an array something like this:
198198
199199
Array( [A, (15., 3)], [B, (30., 2)], [Z, (28., 4)])
200200
201-
202-
203-
sumCount = rdd.combineByKey(lambda value: (value, value*value, 1),
204-
lambda x, value: (x[0] + value, x[1] + value*value, x[2] + 1),
205-
lambda x, y: (x[0] + y[0], x[1] + y[1], x[2] + y[2])
206-
)
207201
````

0 commit comments

Comments
 (0)