Package org.apache.spark

Class SparkStageInfoImpl

Object

org.apache.spark.SparkStageInfoImpl

All Implemented Interfaces:

Serializable, SparkStageInfo

public class SparkStageInfoImpl
extends Object
implements SparkStageInfo

See Also:

• Serialized Form

Constructor Summary

Constructors

Constructor	Description
SparkStageInfoImpl(int stageId, int currentAttemptId, long submissionTime, String name, int numTasks, int numActiveTasks, int numCompletedTasks, int numFailedTasks)

Method Summary

Modifier and Type	Method	Description
int	currentAttemptId()
String	name()
int	numActiveTasks()
int	numCompletedTasks()
int	numFailedTasks()
int	numTasks()
int	stageId()
long	submissionTime()

Methods inherited from class java.lang.Object

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

Constructor Details

SparkStageInfoImpl

public SparkStageInfoImpl(int stageId,
 int currentAttemptId,
 long submissionTime,
 String name,
 int numTasks,
 int numActiveTasks,
 int numCompletedTasks,
 int numFailedTasks)

Method Details

currentAttemptId

public int currentAttemptId()

Specified by:

currentAttemptId in interface SparkStageInfo

name

public String name()

Specified by:

name in interface SparkStageInfo

numActiveTasks

public int numActiveTasks()

Specified by:

numActiveTasks in interface SparkStageInfo

numCompletedTasks

public int numCompletedTasks()

Specified by:

numCompletedTasks in interface SparkStageInfo

numFailedTasks

public int numFailedTasks()

Specified by:

numFailedTasks in interface SparkStageInfo

numTasks

public int numTasks()

Specified by:

numTasks in interface SparkStageInfo

stageId

public int stageId()

Specified by:

stageId in interface SparkStageInfo

submissionTime

public long submissionTime()

Specified by:

submissionTime in interface SparkStageInfo