Package org.apache.spark.util

Class AccumulatorPartialVal<PARTIAL>

Object

org.apache.spark.util.AccumulatorPartialVal<PARTIAL>

All Implemented Interfaces:

Serializable, scala.Equals, scala.Product

public class AccumulatorPartialVal<PARTIAL>
extends Object
implements scala.Product, Serializable

See Also:

• Serialized Form

Constructor Summary

Constructors

Constructor	Description
AccumulatorPartialVal(PARTIAL partialMergeVal, int rddId, int rddPartitionId, int rddNumPartitions, scala.Option<String> rddScopeId, int stageId, int stageAttemptId, int taskAttemptNumber, scala.Option<Object> sqlExecutionId)

Method Summary

Modifier and Type	Method	Description
scala.Tuple3<Object,Object,Object>	attempt()	Tuple of stage id, stage attempt id and taskAttemptNumber, defining the order of attempts.
PARTIAL	partialMergeVal()
int	rddId()
int	rddNumPartitions()
int	rddPartitionId()
scala.Option<String>	rddScopeId()
scala.Option<Object>	sqlExecutionId()
int	stageAttemptId()
int	stageId()
int	taskAttemptNumber()
String	toString()

Methods inherited from class java.lang.Object

equals, getClass, hashCode, notify, notifyAll, wait, wait, wait

Methods inherited from interface scala.Equals

canEqual, equals

Methods inherited from interface scala.Product

productArity, productElement, productElementName, productElementNames, productIterator, productPrefix

Constructor Details

AccumulatorPartialVal

public AccumulatorPartialVal(PARTIAL partialMergeVal,
 int rddId,
 int rddPartitionId,
 int rddNumPartitions,
 scala.Option<String> rddScopeId,
 int stageId,
 int stageAttemptId,
 int taskAttemptNumber,
 scala.Option<Object> sqlExecutionId)

Method Details

partialMergeVal

public PARTIAL partialMergeVal()

rddId

public int rddId()

rddPartitionId

public int rddPartitionId()

rddNumPartitions

public int rddNumPartitions()

rddScopeId

public scala.Option<String> rddScopeId()

stageId

public int stageId()

stageAttemptId

public int stageAttemptId()

taskAttemptNumber

public int taskAttemptNumber()

sqlExecutionId

public scala.Option<Object> sqlExecutionId()

toString

public String toString()

Overrides:

toString in class Object

attempt

public scala.Tuple3<Object,Object,Object> attempt()

Tuple of stage id, stage attempt id and taskAttemptNumber, defining the order of attempts.