Skip to content

Commit

Permalink
Adding missing file
Browse files Browse the repository at this point in the history
  • Loading branch information
pwendell committed Jul 25, 2014
1 parent 5d8b156 commit 64d405f
Showing 1 changed file with 21 additions and 0 deletions.
Original file line number Diff line number Diff line change
@@ -0,0 +1,21 @@
package org.apache.spark.scheduler

import org.apache.spark.annotation.DeveloperApi

/**
* :: DeveloperApi ::
* Information about an [[org.apache.spark.Accumulable]] modified during a task or stage.
*/
@DeveloperApi
class AccumulableInfo (
val id: Long,
val name: String,
val update: Option[String], // represents a partial update within a task
val value: String) { }

object AccumulableInfo {
def apply(id: Long, name: String, update: Option[String], value: String) =
new AccumulableInfo(id, name, update, value)

def apply(id: Long, name: String, value: String) = new AccumulableInfo(id, name, None, value)
}

0 comments on commit 64d405f

Please sign in to comment.