Top Inners Fields Constructors Methods

org.terracotta.statistics.derived

public Class EventRateSimpleMovingAverage

Class Inheritance

extends Object
implements ChainedEventObserver, ValueStatistic<Double>

java.lang.Object
org.terracotta.statistics.derived.EventRateSimpleMovingAverage

All Implemented Interfaces

org.terracotta.statistics.ValueStatistic, org.terracotta.statistics.observer.ChainedEventObserver, org.terracotta.statistics.observer.ChainedObserver

Static Imports

org.terracotta.statistics.Time.time

Author: cdennis

Nested and Inner Type Summary

Modifier and Type	Class and Description
pack-priv static class	EventRateSimpleMovingAverage.CounterPartition

Field Summary

Modifier and Type	Field and Description
private final AtomicReference<EventRateSimpleMovingAverage.CounterPartition>	activePartition
private final Queue<EventRateSimpleMovingAverage.CounterPartition>	archive
private static final int	PARTITION_COUNT
private volatile long	partitionSize
private volatile long	windowSize

Constructor Summary

Access	Constructor and Description
public	EventRateSimpleMovingAverage(long time, TimeUnit unit)

Method Summary

Modifier and Type	Method and Description
private void	archive(EventRateSimpleMovingAverage.CounterPartition partition)
public void	event(long the time of the event time, long... the event parameters parameters) Implements org.terracotta.statistics.observer.ChainedEventObserver.event. Called to indicate an event happened.
public Double	rate(TimeUnit base)
public Double	rateUsingSeconds()
public void	setWindow(long time, TimeUnit unit)
public Double	value() Implements org.terracotta.statistics.ValueStatistic.value.

Inherited from java.lang.Object:: clone equals finalize getClass hashCode notify notifyAll toString wait wait wait

Field Detail

activePartition	back to summary
private final AtomicReference<EventRateSimpleMovingAverage.CounterPartition> activePartition

archive	back to summary
private final Queue<EventRateSimpleMovingAverage.CounterPartition> archive

PARTITION_COUNT	back to summary
private static final int PARTITION_COUNT

partitionSize	back to summary
private volatile long partitionSize

windowSize	back to summary
private volatile long windowSize

Constructor Detail

EventRateSimpleMovingAverage	back to summary
public EventRateSimpleMovingAverage(long time, TimeUnit unit)

Method Detail

archive	back to summary
private void archive(EventRateSimpleMovingAverage.CounterPartition partition)

event

back to summary

public void event(long time, long... parameters)

Implements org.terracotta.statistics.observer.ChainedEventObserver.event.

Doc from org.terracotta.statistics.observer.ChainedEventObserver.event.

Called to indicate an event happened.

Parameters

time:long: the time of the event
parameters:long[]: the event parameters

Annotations

@Override

rate	back to summary
public Double rate(TimeUnit base)

rateUsingSeconds	back to summary
public Double rateUsingSeconds()

setWindow	back to summary
public void setWindow(long time, TimeUnit unit)

value

back to summary

public Double value()

Implements org.terracotta.statistics.ValueStatistic.value.

Annotations

@Override

org.terracotta.statistics.derived back to summary

pack-priv Class EventRateSimpleMovingAverage.CounterPartition

Class Inheritance

extends LongAdder

java.lang.Object
java.lang.Number
java.util.concurrent.atomic.Striped64
java.util.concurrent.atomic.LongAdder
org.terracotta.statistics.derived.EventRateSimpleMovingAverage.CounterPartition

Field Summary

Modifier and Type	Field and Description
private final long	end
private final long	start

Constructor Summary

Access	Constructor and Description
pack-priv	CounterPartition(long start, long length)

Method Summary

Modifier and Type	Method and Description
public long	end()
public boolean	isBefore(long time)
public long	start()
public boolean	targetFor(long time)

Inherited from java.util.concurrent.atomic.LongAdder:: add decrement doubleValue floatValue increment intValue longValue reset sum sumThenReset toString

Field Detail

end	back to summary
private final long end

start	back to summary
private final long start

Constructor Detail

CounterPartition	back to summary
pack-priv CounterPartition(long start, long length)

Method Detail

end	back to summary
public long end()

isBefore	back to summary
public boolean isBefore(long time)

start	back to summary
public long start()

targetFor	back to summary
public boolean targetFor(long time)