Package org.apache.druid.java.util.common.concurrent

Class DelayMetricEmittingScheduledExecutorService

java.lang.Object

org.apache.druid.java.util.common.concurrent.DecoratedExecutorService

org.apache.druid.java.util.common.concurrent.DecoratedScheduledExecutorService

org.apache.druid.java.util.common.concurrent.DelayMetricEmittingScheduledExecutorService

All Implemented Interfaces:

Executor, ExecutorService, ScheduledExecutorService

public class DelayMetricEmittingScheduledExecutorService
extends DecoratedScheduledExecutorService

A DecoratedScheduledExecutorService that emits a scheduling delay metric each time a task runs. The metric value is the difference between the actual time from submission to execution and the intended delay, in milliseconds, floored at zero.

Use ScheduledExecutors.emittingDelayMetric(java.util.concurrent.ScheduledExecutorService, org.apache.druid.java.util.emitter.service.ServiceEmitter, java.lang.String, java.util.Map<java.lang.String, java.lang.Object>) for convenience.

Nested Class Summary

Nested classes/interfaces inherited from class org.apache.druid.java.util.common.concurrent.DecoratedExecutorService

DecoratedExecutorService.Decorator

Field Summary

Fields inherited from class org.apache.druid.java.util.common.concurrent.DecoratedExecutorService

decorator, exec

Constructor Summary

Constructors

Constructor	Description
DelayMetricEmittingScheduledExecutorService(ScheduledExecutorService delegate, ServiceEmitter emitter, String metricName, Map<String,Object> metricDimensions)

Method Summary

Methods inherited from class org.apache.druid.java.util.common.concurrent.DecoratedScheduledExecutorService

schedule, schedule, scheduleAtFixedRate, scheduleWithFixedDelay

Methods inherited from class org.apache.druid.java.util.common.concurrent.DecoratedExecutorService

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

Methods inherited from class java.lang.Object

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

Methods inherited from interface java.util.concurrent.Executor

execute

Methods inherited from interface java.util.concurrent.ExecutorService

awaitTermination, invokeAll, invokeAll, invokeAny, invokeAny, isShutdown, isTerminated, shutdown, shutdownNow, submit, submit, submit

Constructor Details

DelayMetricEmittingScheduledExecutorService

public DelayMetricEmittingScheduledExecutorService(ScheduledExecutorService delegate,
 ServiceEmitter emitter,
 String metricName,
 Map<String,Object> metricDimensions)