ODIn/spark-instrumented-optimizer
1
0
Fork 0
Code Issues Pull requests Projects Releases Wiki Activity

Merge branch 'dev' of github.com:radlab/spark into dev

Browse source
This commit is contained in:
root 2012-09-05 22:26:49 +00:00
parent 1d6b36d3c3 3fa0d7f0c9
commit ed937a821f
1 changed files with 2 additions and 1 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

3
core/src/main/scala/spark/BlockRDD.scala
View file

@ -7,7 +7,8 @@ class BlockRDDSplit(val blockId: String, idx: Int) extends Split {
}
class BlockRDD[T: ClassManifest](sc: SparkContext, blockIds: Array[String]) extends RDD[T](sc) {
class BlockRDD[T: ClassManifest](sc: SparkContext, @transient blockIds: Array[String])
extends RDD[T](sc) {
@transient
val splits_ = (0 until blockIds.size).map(i => {