public class JobStatisticsVertexStage extends Object
Constructor and Description |
---|
JobStatisticsVertexStage() |
Modifier and Type | Method and Description |
---|---|
ResourceUsageStatistics |
allocatedContainerCpuCoreCount()
Get the statistics information for the allocated container CPU core count.
|
ResourceUsageStatistics |
allocatedContainerMemSize()
Get the statistics information for the allocated container memory size.
|
Long |
dataRead()
Get the amount of data read, in bytes.
|
Long |
dataReadCrossPod()
Get the amount of data read across multiple pods, in bytes.
|
Long |
dataReadIntraPod()
Get the amount of data read in one pod, in bytes.
|
Long |
dataToRead()
Get the amount of data remaining to be read, in bytes.
|
Long |
dataWritten()
Get the amount of data written, in bytes.
|
Integer |
duplicateDiscardCount()
Get the number of duplicates that were discarded.
|
Integer |
estimatedVertexCpuCoreCount()
Get the estimated vertex CPU core count.
|
Long |
estimatedVertexMemSize()
Get the estimated vertex memory size, in bytes.
|
Integer |
estimatedVertexPeakCpuCoreCount()
Get the estimated vertex peak CPU core count.
|
Integer |
failedCount()
Get the number of failures that occured in this stage.
|
JobStatisticsVertex |
maxDataReadVertex()
Get the vertex with the maximum amount of data read.
|
JobStatisticsVertex |
maxExecutionTimeVertex()
Get the vertex with the maximum execution time.
|
JobStatisticsVertex |
maxPeakMemUsageVertex()
Get the vertex with the maximum peak memory usage.
|
Long |
maxVertexDataRead()
Get the maximum amount of data read in a single vertex, in bytes.
|
Long |
minVertexDataRead()
Get the minimum amount of data read in a single vertex, in bytes.
|
Integer |
readFailureCount()
Get the number of read failures in this stage.
|
Integer |
revocationCount()
Get the number of vertices that were revoked during this stage.
|
Integer |
runningCount()
Get the number of currently running vertices in this stage.
|
Integer |
scheduledCount()
Get the number of currently scheduled vertices in this stage.
|
String |
stageName()
Get the name of this stage in job execution.
|
Integer |
succeededCount()
Get the number of vertices that succeeded in this stage.
|
Long |
tempDataWritten()
Get the amount of temporary data written, in bytes.
|
Integer |
totalCount()
Get the total vertex count for this stage.
|
org.joda.time.Period |
totalExecutionTime()
Get the sum of the total execution time of all the vertices in the stage.
|
org.joda.time.Period |
totalFailedTime()
Get the amount of time that failed vertices took up in this stage.
|
Long |
totalPeakMemUsage()
Get the sum of the peak memory usage of all the vertices in the stage, in bytes.
|
Integer |
totalProgress()
Get the current progress of this stage, as a percentage.
|
org.joda.time.Period |
totalSucceededTime()
Get the amount of time all successful vertices took in this stage.
|
ResourceUsageStatistics |
usedVertexCpuCoreCount()
Get the statistics information for the used vertex CPU core count.
|
ResourceUsageStatistics |
usedVertexPeakMemSize()
Get the statistics information for the used vertex peak memory size.
|
JobStatisticsVertexStage |
withAllocatedContainerCpuCoreCount(ResourceUsageStatistics allocatedContainerCpuCoreCount)
Set the statistics information for the allocated container CPU core count.
|
JobStatisticsVertexStage |
withAllocatedContainerMemSize(ResourceUsageStatistics allocatedContainerMemSize)
Set the statistics information for the allocated container memory size.
|
JobStatisticsVertexStage |
withMaxDataReadVertex(JobStatisticsVertex maxDataReadVertex)
Set the vertex with the maximum amount of data read.
|
JobStatisticsVertexStage |
withMaxExecutionTimeVertex(JobStatisticsVertex maxExecutionTimeVertex)
Set the vertex with the maximum execution time.
|
JobStatisticsVertexStage |
withMaxPeakMemUsageVertex(JobStatisticsVertex maxPeakMemUsageVertex)
Set the vertex with the maximum peak memory usage.
|
JobStatisticsVertexStage |
withUsedVertexCpuCoreCount(ResourceUsageStatistics usedVertexCpuCoreCount)
Set the statistics information for the used vertex CPU core count.
|
JobStatisticsVertexStage |
withUsedVertexPeakMemSize(ResourceUsageStatistics usedVertexPeakMemSize)
Set the statistics information for the used vertex peak memory size.
|
public Long dataRead()
public Long dataReadCrossPod()
public Long dataReadIntraPod()
public Long dataToRead()
public Long dataWritten()
public Integer duplicateDiscardCount()
public Integer failedCount()
public Long maxVertexDataRead()
public Long minVertexDataRead()
public Integer readFailureCount()
public Integer revocationCount()
public Integer runningCount()
public Integer scheduledCount()
public String stageName()
public Integer succeededCount()
public Long tempDataWritten()
public Integer totalCount()
public org.joda.time.Period totalFailedTime()
public Integer totalProgress()
public org.joda.time.Period totalSucceededTime()
public Long totalPeakMemUsage()
public org.joda.time.Period totalExecutionTime()
public JobStatisticsVertex maxDataReadVertex()
public JobStatisticsVertexStage withMaxDataReadVertex(JobStatisticsVertex maxDataReadVertex)
maxDataReadVertex
- the maxDataReadVertex value to setpublic JobStatisticsVertex maxExecutionTimeVertex()
public JobStatisticsVertexStage withMaxExecutionTimeVertex(JobStatisticsVertex maxExecutionTimeVertex)
maxExecutionTimeVertex
- the maxExecutionTimeVertex value to setpublic JobStatisticsVertex maxPeakMemUsageVertex()
public JobStatisticsVertexStage withMaxPeakMemUsageVertex(JobStatisticsVertex maxPeakMemUsageVertex)
maxPeakMemUsageVertex
- the maxPeakMemUsageVertex value to setpublic Integer estimatedVertexCpuCoreCount()
public Integer estimatedVertexPeakCpuCoreCount()
public Long estimatedVertexMemSize()
public ResourceUsageStatistics allocatedContainerCpuCoreCount()
public JobStatisticsVertexStage withAllocatedContainerCpuCoreCount(ResourceUsageStatistics allocatedContainerCpuCoreCount)
allocatedContainerCpuCoreCount
- the allocatedContainerCpuCoreCount value to setpublic ResourceUsageStatistics allocatedContainerMemSize()
public JobStatisticsVertexStage withAllocatedContainerMemSize(ResourceUsageStatistics allocatedContainerMemSize)
allocatedContainerMemSize
- the allocatedContainerMemSize value to setpublic ResourceUsageStatistics usedVertexCpuCoreCount()
public JobStatisticsVertexStage withUsedVertexCpuCoreCount(ResourceUsageStatistics usedVertexCpuCoreCount)
usedVertexCpuCoreCount
- the usedVertexCpuCoreCount value to setpublic ResourceUsageStatistics usedVertexPeakMemSize()
public JobStatisticsVertexStage withUsedVertexPeakMemSize(ResourceUsageStatistics usedVertexPeakMemSize)
usedVertexPeakMemSize
- the usedVertexPeakMemSize value to setCopyright © 2019. All rights reserved.