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

Class TimelineMetricCacheEntryFactory

java.lang.Object

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

All Implemented Interfaces:

net.sf.ehcache.constructs.blocking.CacheEntryFactory, net.sf.ehcache.constructs.blocking.UpdatingCacheEntryFactory

public class TimelineMetricCacheEntryFactory
extends Object
implements net.sf.ehcache.constructs.blocking.UpdatingCacheEntryFactory

Constructor Summary

Constructors

Constructor and Description
TimelineMetricCacheEntryFactory(Configuration configuration)

Method Summary

Modifier and Type	Method and Description
Object	createEntry(Object key) This method is called on a get element from cache call when key is not found in cache, returns a value for the key to be cached.
protected Long	getRefreshRequestEndTime(Long existingSeriesStartTime, Long existingSeriesEndTime, Long requestedEndTime)
protected Long	getRefreshRequestStartTime(Long existingSeriesStartTime, Long existingSeriesEndTime, Long requestedStartTime)
void	updateEntryValue(Object key, Object value) Called on a get call for existing values in the cache, the necessary locking code is present in the get call and this call should update the value of the cache entry before returning.
protected void	updateTimelineMetricsInCache(org.apache.hadoop.metrics2.sink.timeline.TimelineMetrics newMetrics, TimelineMetricsCacheValue timelineMetricsCacheValue, Long requestedStartTime, Long requestedEndTime, boolean removeAll) Update cache with new timeseries data

Methods inherited from class java.lang.Object

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

Constructor Detail

TimelineMetricCacheEntryFactory

@Inject
public TimelineMetricCacheEntryFactory(Configuration configuration)

Method Detail

createEntry

public Object createEntry(Object key)
                   throws Exception

This method is called on a get element from cache call when key is not found in cache, returns a value for the key to be cached.

Specified by:

createEntry in interface net.sf.ehcache.constructs.blocking.CacheEntryFactory

Parameters:

key - @org.apache.ambari.server.controller.metrics.timeline.cache.TimelineAppMetricCacheKey

Returns:

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

Throws:

Exception

updateEntryValue

public void updateEntryValue(Object key,
                             Object value)
                      throws Exception

Called on a get call for existing values in the cache, the necessary locking code is present in the get call and this call should update the value of the cache entry before returning.

Specified by:

updateEntryValue in interface net.sf.ehcache.constructs.blocking.UpdatingCacheEntryFactory

Parameters:

key - @org.apache.ambari.server.controller.metrics.timeline.cache.TimelineAppMetricCacheKey

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

Throws:

Exception

updateTimelineMetricsInCache

protected void updateTimelineMetricsInCache(org.apache.hadoop.metrics2.sink.timeline.TimelineMetrics newMetrics,
                                            TimelineMetricsCacheValue timelineMetricsCacheValue,
                                            Long requestedStartTime,
                                            Long requestedEndTime,
                                            boolean removeAll)

Update cache with new timeseries data

getRefreshRequestStartTime

protected Long getRefreshRequestStartTime(Long existingSeriesStartTime,
                                          Long existingSeriesEndTime,
                                          Long requestedStartTime)

getRefreshRequestEndTime

protected Long getRefreshRequestEndTime(Long existingSeriesStartTime,
                                        Long existingSeriesEndTime,
                                        Long requestedEndTime)