Package org.apache.druid.query

Class MetricsEmittingQueryProcessingPool

java.lang.Object

com.google.common.collect.ForwardingObject

com.google.common.util.concurrent.ForwardingExecutorService

com.google.common.util.concurrent.ForwardingListeningExecutorService

org.apache.druid.query.ForwardingQueryProcessingPool

org.apache.druid.query.MetricsEmittingQueryProcessingPool

All Implemented Interfaces:

com.google.common.util.concurrent.ListeningExecutorService, Executor, ExecutorService, ExecutorServiceMonitor.MetricEmitter, QueryProcessingPool

public class MetricsEmittingQueryProcessingPool
extends ForwardingQueryProcessingPool
implements ExecutorServiceMonitor.MetricEmitter

Constructor Summary

Constructors

Constructor	Description
MetricsEmittingQueryProcessingPool(com.google.common.util.concurrent.ListeningExecutorService delegate, ScheduledExecutorService timeoutService, ExecutorServiceMonitor executorServiceMonitor)

Method Summary

Modifier and Type	Method	Description
void	emitMetrics(ServiceEmitter emitter, ServiceMetricEvent.Builder metricBuilder)

Methods inherited from class org.apache.druid.query.ForwardingQueryProcessingPool

delegate, shutdown, submitRunnerTask, submitRunnerTask

Methods inherited from class com.google.common.util.concurrent.ForwardingListeningExecutorService

submit, submit, submit

Methods inherited from class com.google.common.util.concurrent.ForwardingExecutorService

awaitTermination, execute, invokeAll, invokeAll, invokeAny, invokeAny, isShutdown, isTerminated, shutdownNow

Methods inherited from class com.google.common.collect.ForwardingObject

toString

Methods inherited from class java.lang.Object

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

Methods inherited from interface java.util.concurrent.Executor

execute

Methods inherited from interface java.util.concurrent.ExecutorService

awaitTermination, invokeAny, invokeAny, isShutdown, isTerminated, shutdownNow

Methods inherited from interface com.google.common.util.concurrent.ListeningExecutorService

awaitTermination, invokeAll, invokeAll, invokeAll, invokeAny, submit, submit, submit

Constructor Details

MetricsEmittingQueryProcessingPool

public MetricsEmittingQueryProcessingPool(com.google.common.util.concurrent.ListeningExecutorService delegate,
 @Nullable
 ScheduledExecutorService timeoutService,
 ExecutorServiceMonitor executorServiceMonitor)

Method Details

emitMetrics

public void emitMetrics(ServiceEmitter emitter,
 ServiceMetricEvent.Builder metricBuilder)

Specified by:

emitMetrics in interface ExecutorServiceMonitor.MetricEmitter