spark技术分享SubtractedRDD
|
Caution
|
FIXME |
Computing Partition (in TaskContext) — compute Method
|
1 2 3 4 5 |
compute(p: Partition, context: TaskContext): Iterator[(K, V)] |
|
Note
|
compute is part of RDD Contract to compute a partition (in a TaskContext).
|
compute…FIXME
getDependencies Method
|
Caution
|
FIXME |
