org.apache.ambari.server.controller.metrics.timeline.cache

Class TimelineMetricCache

java.lang.Object

net.sf.ehcache.constructs.EhcacheDecoratorAdapter

net.sf.ehcache.constructs.blocking.BlockingCache

net.sf.ehcache.constructs.blocking.SelfPopulatingCache

net.sf.ehcache.constructs.blocking.UpdatingSelfPopulatingCache

org.apache.ambari.server.controller.metrics.timeline.cache.TimelineMetricCache

All Implemented Interfaces:

Cloneable, net.sf.ehcache.Ehcache, net.sf.ehcache.terracotta.InternalEhcache

public class TimelineMetricCache
extends net.sf.ehcache.constructs.blocking.UpdatingSelfPopulatingCache

Field Summary

Fields inherited from class net.sf.ehcache.constructs.blocking.SelfPopulatingCache

factory

Fields inherited from class net.sf.ehcache.constructs.blocking.BlockingCache

timeoutMillis

Fields inherited from class net.sf.ehcache.constructs.EhcacheDecoratorAdapter

underlyingCache

Constructor Summary

Constructors

Constructor and Description
TimelineMetricCache(net.sf.ehcache.Ehcache cache, net.sf.ehcache.constructs.blocking.UpdatingCacheEntryFactory factory) Creates a SelfPopulatingCache.

Method Summary

Modifier and Type	Method and Description
net.sf.ehcache.Element	get(Object key) Set new time bounds on the cache key so that update can use the new query window.
org.apache.hadoop.metrics2.sink.timeline.TimelineMetrics	getAppTimelineMetricsFromCache(TimelineAppMetricCacheKey key) Get metrics for an app grouped by the requested @TemporalInfo which is a part of the @TimelineAppMetricCacheKey

Methods inherited from class net.sf.ehcache.constructs.blocking.UpdatingSelfPopulatingCache

refresh, update

Methods inherited from class net.sf.ehcache.constructs.blocking.SelfPopulatingCache

makeAndCheckElement, refresh, refresh, refresh, refreshElement, refreshElement

Methods inherited from class net.sf.ehcache.constructs.blocking.BlockingCache

get, getAllWithLoader, getCache, getLockForKey, getTimeoutMillis, getWithLoader, liveness, load, loadAll, put, put, putIfAbsent, putIfAbsent, putQuiet, putWithWriter, registerCacheLoader, setTimeoutMillis, unregisterCacheLoader

Methods inherited from class net.sf.ehcache.constructs.EhcacheDecoratorAdapter

acquireReadLockOnKey, acquireWriteLockOnKey, addPropertyChangeListener, bootstrap, calculateInMemorySize, calculateOffHeapSize, calculateOnDiskSize, clone, createQuery, disableDynamicFeatures, dispose, evictExpiredElements, flush, getAll, getBootstrapCacheLoader, getCacheConfiguration, getCacheEventNotificationService, getCacheExceptionHandler, getCacheManager, getDiskStoreSize, getGuid, getInternalContext, getKeys, getKeysNoDuplicateCheck, getKeysWithExpiryCheck, getMemoryStoreSize, getName, getOffHeapStoreSize, getQuiet, getQuiet, getRegisteredCacheExtensions, getRegisteredCacheLoaders, getRegisteredCacheWriter, getSearchAttribute, getSearchAttributes, getSize, getStatistics, getStatus, getWriterManager, hasAbortedSizeOf, initialise, isClusterBulkLoadEnabled, isClusterCoherent, isDisabled, isElementInMemory, isElementInMemory, isElementOnDisk, isElementOnDisk, isExpired, isKeyInCache, isNodeBulkLoadEnabled, isNodeCoherent, isReadLockedByCurrentThread, isSearchable, isValueInCache, isWriteLockedByCurrentThread, putAll, recalculateSize, registerCacheExtension, registerCacheWriter, registerDynamicAttributesExtractor, releaseReadLockOnKey, releaseWriteLockOnKey, remove, remove, remove, remove, removeAll, removeAll, removeAll, removeAll, removeAndReturnElement, removeElement, removePropertyChangeListener, removeQuiet, removeQuiet, removeWithWriter, replace, replace, setBootstrapCacheLoader, setCacheExceptionHandler, setCacheManager, setDisabled, setName, setNodeBulkLoadEnabled, setNodeCoherent, setTransactionManagerLookup, toString, tryReadLockOnKey, tryWriteLockOnKey, unregisterCacheExtension, unregisterCacheWriter, waitUntilClusterBulkLoadComplete, waitUntilClusterCoherent

Methods inherited from class java.lang.Object

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

Constructor Detail

TimelineMetricCache

public TimelineMetricCache(net.sf.ehcache.Ehcache cache,
                           net.sf.ehcache.constructs.blocking.UpdatingCacheEntryFactory factory)
                    throws net.sf.ehcache.CacheException

Creates a SelfPopulatingCache.

Parameters:

cache - @Cache

factory - @CacheEntryFactory

Throws:

net.sf.ehcache.CacheException

Method Detail

getAppTimelineMetricsFromCache

public org.apache.hadoop.metrics2.sink.timeline.TimelineMetrics getAppTimelineMetricsFromCache(TimelineAppMetricCacheKey key)
                                                                                        throws IllegalArgumentException,
                                                                                               IOException

Get metrics for an app grouped by the requested @TemporalInfo which is a part of the @TimelineAppMetricCacheKey

Parameters:

key - @TimelineAppMetricCacheKey

Returns:

@org.apache.hadoop.metrics2.sink.timeline.TimelineMetrics

Throws:

IllegalArgumentException

IOException

get

public net.sf.ehcache.Element get(Object key)
                           throws net.sf.ehcache.constructs.blocking.LockTimeoutException

Set new time bounds on the cache key so that update can use the new query window. We do this quietly which means regular get/update logic is not invoked.

Specified by:

get in interface net.sf.ehcache.Ehcache

Overrides:

get in class net.sf.ehcache.constructs.blocking.UpdatingSelfPopulatingCache

Throws:

net.sf.ehcache.constructs.blocking.LockTimeoutException