Package org.terracotta.statistics

Class StatisticMapper<SOURCE extends Enum<SOURCE>,TARGET extends Enum<TARGET>>

java.lang.Object

org.terracotta.statistics.StatisticMapper<SOURCE,TARGET>

All Implemented Interfaces:

OperationObserver<TARGET>, OperationStatistic<TARGET>, SourceStatistic<ChainedOperationObserver<? super TARGET>>

public class StatisticMapper<SOURCE extends Enum<SOURCE>,TARGET extends Enum<TARGET>>
extends Object
implements OperationStatistic<TARGET>

Field Summary

Fields

Modifier and Type	Field	Description
private final ConcurrentMap<ChainedOperationObserver<? super TARGET>,ChainedOperationObserver<SOURCE>>	derivedStats
private final Map<SOURCE,TARGET>	reverseTranslation
private final Class<SOURCE>	sourceType
private final OperationStatistic<SOURCE>	statistic
private final Class<TARGET>	targetType
private final Map<TARGET,Set<SOURCE>>	translation

Constructor Summary

Constructors

Constructor	Description
StatisticMapper(Map<TARGET,Set<SOURCE>> translation, OperationStatistic<SOURCE> statistic)

Method Summary

Modifier and Type	Method	Description
void	addDerivedStatistic(ChainedOperationObserver<? super TARGET> derived)	Register the given Observer to be called by this SourceStatistic
void	begin()	Called immediately prior to the operation beginning.
long	count(TARGET type)	Return the count of operations with the given type.
void	end(TARGET result)	Called immediately after the operation completes with no interesting parameters, and with the same thread the called {OperationObserver.begin()} before.
Collection<ChainedOperationObserver<? super TARGET>>	getDerivedStatistics()	Retrieve all registered statistics.
void	removeDerivedStatistic(ChainedOperationObserver<? super TARGET> derived)	Remove the given registered Observer from this SourceStatistic.
private static <B extends Enum<B>, A extends Enum<A>> Map<B,A>	reverse(Map<A,Set<B>> map)
ValueStatistic<Long>	statistic(Set<TARGET> results)
ValueStatistic<Long>	statistic(TARGET result)	Return a ValueStatistic returning the count for the given result.
long	sum()
long	sum(Set<TARGET> types)
Class<TARGET>	type()

Methods inherited from class java.lang.Object

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

Field Details

targetType

private final Class<TARGET extends Enum<TARGET>> targetType

sourceType

private final Class<SOURCE extends Enum<SOURCE>> sourceType

statistic

private final OperationStatistic<SOURCE extends Enum<SOURCE>> statistic

translation

private final Map<TARGET extends Enum<TARGET>,Set<SOURCE extends Enum<SOURCE>>> translation

reverseTranslation

private final Map<SOURCE extends Enum<SOURCE>,TARGET extends Enum<TARGET>> reverseTranslation

derivedStats

private final ConcurrentMap<ChainedOperationObserver<? super TARGET extends Enum<TARGET>>,ChainedOperationObserver<SOURCE extends Enum<SOURCE>>> derivedStats

Constructor Details

StatisticMapper

public StatisticMapper(Map<TARGET,Set<SOURCE>> translation,
 OperationStatistic<SOURCE> statistic)

Method Details

reverse

private static <B extends Enum<B>,
A extends Enum<A>>
Map<B,A> reverse(Map<A,Set<B>> map)

type

public Class<TARGET> type()

Specified by:

type in interface OperationStatistic<SOURCE extends Enum<SOURCE>>

statistic

public ValueStatistic<Long> statistic(TARGET result)

Description copied from interface: OperationStatistic

Return a ValueStatistic returning the count for the given result.

Specified by:

statistic in interface OperationStatistic<SOURCE extends Enum<SOURCE>>

Parameters:

result - the result of interest

Returns:

a ValueStatistic instance

statistic

public ValueStatistic<Long> statistic(Set<TARGET> results)

Specified by:

statistic in interface OperationStatistic<SOURCE extends Enum<SOURCE>>

count

public long count(TARGET type)

Description copied from interface: OperationStatistic

Return the count of operations with the given type.

Specified by:

count in interface OperationStatistic<SOURCE extends Enum<SOURCE>>

Parameters:

type - the result type

Returns:

the operation count

sum

public long sum(Set<TARGET> types)

Specified by:

sum in interface OperationStatistic<SOURCE extends Enum<SOURCE>>

sum

public long sum()

Specified by:

sum in interface OperationStatistic<SOURCE extends Enum<SOURCE>>

addDerivedStatistic

public void addDerivedStatistic(ChainedOperationObserver<? super TARGET> derived)

Description copied from interface: SourceStatistic

Register the given Observer to be called by this SourceStatistic

Specified by:

addDerivedStatistic in interface SourceStatistic<SOURCE extends Enum<SOURCE>>

Parameters:

derived - statistic to be registered

removeDerivedStatistic

public void removeDerivedStatistic(ChainedOperationObserver<? super TARGET> derived)

Description copied from interface: SourceStatistic

Remove the given registered Observer from this SourceStatistic.

Specified by:

removeDerivedStatistic in interface SourceStatistic<SOURCE extends Enum<SOURCE>>

Parameters:

derived - statistic to be removed

getDerivedStatistics

public Collection<ChainedOperationObserver<? super TARGET>> getDerivedStatistics()

Description copied from interface: SourceStatistic

Retrieve all registered statistics.

Specified by:

getDerivedStatistics in interface SourceStatistic<SOURCE extends Enum<SOURCE>>

Returns:

an unmodifiable collection of all derived statistics

begin

public void begin()

Description copied from interface: OperationObserver

Called immediately prior to the operation beginning.

Specified by:

begin in interface OperationObserver<SOURCE extends Enum<SOURCE>>

end

public void end(TARGET result)

Description copied from interface: OperationObserver

Called immediately after the operation completes with no interesting parameters, and with the same thread the called {OperationObserver.begin()} before.

Specified by:

end in interface OperationObserver<SOURCE extends Enum<SOURCE>>

Parameters:

result - the operation result