org.apache.hadoop.hive.llap.metrics

Class LlapDaemonExecutorMetrics

java.lang.Object

org.apache.hadoop.hive.llap.metrics.LlapDaemonExecutorMetrics

All Implemented Interfaces:

org.apache.hadoop.metrics2.MetricsSource

@Metrics(about="LlapDaemon Executor Metrics",
         context="executors")
public class LlapDaemonExecutorMetrics
extends Object
implements org.apache.hadoop.metrics2.MetricsSource

Metrics about the llap daemon executors.

Method Summary

Modifier and Type	Method and Description
void	addMetricsFallOffFailedTimeLost(long timeLost)
void	addMetricsFallOffKilledTimeLost(long timeLost)
void	addMetricsFallOffSuccessTimeLost(long timeLost)
void	addMetricsPreemptionTimeLost(long value)
void	addMetricsPreemptionTimeToKill(long value)
static LlapDaemonExecutorMetrics	create(String displayName, String sessionId, int numExecutors, int[] intervals)
JvmMetrics	getJvmMetrics()
void	getMetrics(org.apache.hadoop.metrics2.MetricsCollector collector, boolean b)
String	getName()
void	incrExecutorTotalExecutionFailed()
void	incrExecutorTotalKilled()
void	incrExecutorTotalRequestsHandled()
void	incrExecutorTotalSuccess()
void	incrTotalEvictedFromWaitQueue()
void	incrTotalRejectedRequests()
void	setCacheMemoryPerInstance(long value)
void	setExecutorNumPreemptableRequests(int value)
void	setExecutorNumQueuedRequests(int value)
void	setJvmMaxMemory(long value)
void	setMemoryPerInstance(long value)
void	setNumExecutorsAvailable(int value)
void	setWaitQueueSize(int size)

Methods inherited from class java.lang.Object

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

Method Detail

create

public static LlapDaemonExecutorMetrics create(String displayName,
                                               String sessionId,
                                               int numExecutors,
                                               int[] intervals)

getMetrics

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

Specified by:

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

incrExecutorTotalRequestsHandled

public void incrExecutorTotalRequestsHandled()

setExecutorNumQueuedRequests

public void setExecutorNumQueuedRequests(int value)

setExecutorNumPreemptableRequests

public void setExecutorNumPreemptableRequests(int value)

setNumExecutorsAvailable

public void setNumExecutorsAvailable(int value)

incrTotalEvictedFromWaitQueue

public void incrTotalEvictedFromWaitQueue()

incrTotalRejectedRequests

public void incrTotalRejectedRequests()

incrExecutorTotalSuccess

public void incrExecutorTotalSuccess()

incrExecutorTotalExecutionFailed

public void incrExecutorTotalExecutionFailed()

addMetricsPreemptionTimeLost

public void addMetricsPreemptionTimeLost(long value)

addMetricsPreemptionTimeToKill

public void addMetricsPreemptionTimeToKill(long value)

addMetricsFallOffSuccessTimeLost

public void addMetricsFallOffSuccessTimeLost(long timeLost)

addMetricsFallOffFailedTimeLost

public void addMetricsFallOffFailedTimeLost(long timeLost)

addMetricsFallOffKilledTimeLost

public void addMetricsFallOffKilledTimeLost(long timeLost)

incrExecutorTotalKilled

public void incrExecutorTotalKilled()

setCacheMemoryPerInstance

public void setCacheMemoryPerInstance(long value)

setMemoryPerInstance

public void setMemoryPerInstance(long value)

setJvmMaxMemory

public void setJvmMaxMemory(long value)

setWaitQueueSize

public void setWaitQueueSize(int size)

getJvmMetrics

public JvmMetrics getJvmMetrics()

getName

public String getName()