org.apache.hadoop.hive.llap.tezplugins.metrics

Class LlapTaskSchedulerMetrics

java.lang.Object

org.apache.hadoop.hive.llap.tezplugins.metrics.LlapTaskSchedulerMetrics

All Implemented Interfaces:

org.apache.hadoop.metrics2.MetricsSource

@Metrics(about="Llap Task Scheduler Metrics",
         context="scheduler")
public class LlapTaskSchedulerMetrics
extends Object
implements org.apache.hadoop.metrics2.MetricsSource

Metrics about the llap task scheduler.

Method Summary

Modifier and Type	Method and Description
static LlapTaskSchedulerMetrics	create(String displayName, String sessionId)
void	decrPendingPreemptionTasksCount()
void	decrPendingTasksCount()
void	decrRunningTasksCount()
void	decrSchedulableTasksCount()
JvmMetrics	getJvmMetrics()
void	getMetrics(org.apache.hadoop.metrics2.MetricsCollector collector, boolean b)
String	getName()
void	incrCompletedDagCount()
void	incrPendingPreemptionTasksCount()
void	incrPendingTasksCount()
void	incrPreemptedTasksCount()
void	incrRunningTasksCount()
void	incrSchedulableTasksCount()
void	incrSchedulableTasksCount(int delta)
void	incrSuccessfulTasksCount()
void	resetWmMetrics()
void	setClusterNodeCount(int value)
void	setCpuCoresPerInstance(int value)
void	setDagId(String dagId)
void	setDisabledNodeCount(int value)
void	setMemoryPerInstance(long value)
void	setNumExecutors(int value)
void	setWmPendingDone(boolean isGuaranteed)
void	setWmPendingFailed(boolean requestedGuaranteed)
void	setWmPendingStarted(boolean isGuaranteed)
void	setWmTaskFinished(boolean isGuaranteed, boolean isPendingUpdate)
void	setWmTaskStarted(boolean isGuaranteed)
void	setWmTotalGuaranteed(int totalGuaranteed)
void	setWmUnusedGuaranteed(int unusedGuaranteed)

Methods inherited from class java.lang.Object

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

Method Detail

create

public static LlapTaskSchedulerMetrics create(String displayName,
                                              String sessionId)

getMetrics

public void getMetrics(org.apache.hadoop.metrics2.MetricsCollector collector,
                       boolean b)

Specified by:

getMetrics in interface org.apache.hadoop.metrics2.MetricsSource

setDagId

public void setDagId(String dagId)

setNumExecutors

public void setNumExecutors(int value)

setMemoryPerInstance

public void setMemoryPerInstance(long value)

setCpuCoresPerInstance

public void setCpuCoresPerInstance(int value)

setClusterNodeCount

public void setClusterNodeCount(int value)

setDisabledNodeCount

public void setDisabledNodeCount(int value)

incrPendingTasksCount

public void incrPendingTasksCount()

decrPendingTasksCount

public void decrPendingTasksCount()

incrSchedulableTasksCount

public void incrSchedulableTasksCount(int delta)

incrSchedulableTasksCount

public void incrSchedulableTasksCount()

decrSchedulableTasksCount

public void decrSchedulableTasksCount()

incrSuccessfulTasksCount

public void incrSuccessfulTasksCount()

incrRunningTasksCount

public void incrRunningTasksCount()

decrRunningTasksCount

public void decrRunningTasksCount()

incrPreemptedTasksCount

public void incrPreemptedTasksCount()

incrCompletedDagCount

public void incrCompletedDagCount()

incrPendingPreemptionTasksCount

public void incrPendingPreemptionTasksCount()

decrPendingPreemptionTasksCount

public void decrPendingPreemptionTasksCount()

setWmPendingStarted

public void setWmPendingStarted(boolean isGuaranteed)

setWmPendingDone

public void setWmPendingDone(boolean isGuaranteed)

setWmPendingFailed

public void setWmPendingFailed(boolean requestedGuaranteed)

setWmTaskStarted

public void setWmTaskStarted(boolean isGuaranteed)

setWmTaskFinished

public void setWmTaskFinished(boolean isGuaranteed,
                              boolean isPendingUpdate)

setWmTotalGuaranteed

public void setWmTotalGuaranteed(int totalGuaranteed)

setWmUnusedGuaranteed

public void setWmUnusedGuaranteed(int unusedGuaranteed)

resetWmMetrics

public void resetWmMetrics()

getJvmMetrics

public JvmMetrics getJvmMetrics()

getName

public String getName()