blob: db33c9ff4483ea791c0e0b2b87fb0ceefd48eb63 (
plain) (
blame)
1
2
3
4
5
6
7
8
9
|
package spark
import scala.collection.mutable.Map
// Task result. Also contains updates to accumulator variables.
// TODO: Use of distributed cache to return result is a hack to get around
// what seems to be a bug with messages over 60KB in libprocess; fix it
@serializable
private class TaskResult[T](val value: T, val accumUpdates: Map[Long, Any])
|
