com.activeviam.frtb.core.postprocessor.ima.impl

Class SES

java.lang.Object

com.quartetfs.biz.pivot.postprocessing.impl.AAdvancedPostProcessor<Double>

com.activeviam.frtb.core.postprocessor.ima.impl.SES

All Implemented Interfaces:

IPostProcessorPartitioningManagerAware, com.quartetfs.biz.pivot.postprocessing.IAggregatedMeasureAware, com.quartetfs.biz.pivot.postprocessing.IPartitionedPostProcessor<Double>, com.quartetfs.biz.pivot.postprocessing.IPostProcessor<Double>, com.quartetfs.fwk.types.IExtendedPluginValue, Serializable

Direct Known Subclasses:

SESEuler

@QuartetExtendedPluginValue(intf=com.quartetfs.biz.pivot.postprocessing.IPostProcessor.class,
                            key="SES")
public class SES
extends com.quartetfs.biz.pivot.postprocessing.impl.AAdvancedPostProcessor<Double>
implements com.quartetfs.biz.pivot.postprocessing.IPartitionedPostProcessor<Double>, IPostProcessorPartitioningManagerAware

See Also:

Serialized Form

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static class	SES.UnderlyingMeasuresPrefetcher

Field Summary

Fields

Modifier and Type	Field and Description
protected com.qfs.agg.IAggregationFunction	aggregationFunction
static double	DEFAULT_RHO
static String	ISES_PREFETCHER_NAME
protected IPostProcessorPartitioningManager	partitioningManager
protected IPostProcessorPartitioningManager.Factory	partitioningManagerFactory
static String	PLUGIN_KEY
protected Double	rho
static String	RHO_PROPERTY
protected com.quartetfs.biz.pivot.cube.hierarchy.ILevelInfo	riskClassLevel
protected com.quartetfs.biz.pivot.cube.hierarchy.ILevelInfo	riskFactorLevel
static String	SES_PREFETCHER_NAME

Fields inherited from class com.quartetfs.biz.pivot.postprocessing.impl.AAdvancedPostProcessor

aggregatedMeasureName, ANALYSIS_LEVELS_PROPERTY, analysisLevelsToExpand, continuousQueryHandlerKeys, derivedContextDependencies, evaluator, EVALUATOR, explicitContextDependencies, logger, measuresProvider, name, OUTPUT_TYPE, outputType, pivot, prefetchers, PRINT_TIMINGS, printTimings, properties, underlyingMeasures

Fields inherited from interface com.quartetfs.biz.pivot.postprocessing.IPartitionedPostProcessor

DEFAULT_PARTITIONING_ON_RANGE_LEVELS, DEFAULT_PARTITIONING_ON_RANGE_LEVELS_PROPERTY

Fields inherited from interface com.quartetfs.biz.pivot.postprocessing.IPostProcessor

CONTINUOUS_QUERY_HANDLER_KEYS, IS_PARTITIONED_ON_RANGE_LEVELS_PROPERTY, SEPARATOR, UNDERLYING_MEASURES

Fields inherited from interface com.activeviam.frtb.core.postprocessor.IPostProcessorPartitioningManagerAware

PROPERTY_NAME

Constructor Summary

Constructors

Constructor and Description
SES(String name, com.quartetfs.biz.pivot.cube.hierarchy.measures.IPostProcessorCreationContext creationContext)

Method Summary

Modifier and Type	Method and Description
static Double	calculateSES(double rho, double sesSum, double sesSumSq, Map<String,Double> isesSumSq)
static Double	calculateSES(double rho, Double sesSum, Double sesSumSq, Map<String,Double> isesSumSq)
void	compute(com.quartetfs.biz.pivot.ILocation location, com.quartetfs.biz.pivot.query.aggregates.IAdvancedAggregatesRetriever retriever)
protected com.quartetfs.biz.pivot.postprocessing.IPrefetcher<Void>	createISESPrefetcher()
protected com.quartetfs.biz.pivot.postprocessing.IPrefetcher<Void>	createSESPrefetcher()
static com.quartetfs.biz.pivot.definitions.IPostProcessorDescription	getPostProcessorDescription(Properties env, String measureName, String esSesMeasure, String esISesMeasure, String folder, boolean visible) Constructs the postprocessor definition
protected double	getRho() The value of parameter rho in the SES calculation.
String	getType()
protected List<com.quartetfs.biz.pivot.cube.hierarchy.IHierarchyInfo>	hierarchies(String seperator, String description)
void	init(Properties properties)
protected Collection<com.quartetfs.biz.pivot.ILocation>	isesPrefetcherComputeLocations(com.quartetfs.biz.pivot.ILocation location)
protected Map<com.quartetfs.biz.pivot.cube.hierarchy.IHierarchyInfo,com.quartetfs.biz.pivot.cube.hierarchy.ILevelInfo>	levels(String seperator, String description)
void	reduce(com.quartetfs.biz.pivot.ILocation location, List<com.quartetfs.biz.pivot.cellset.IAggregatesRetrievalResult> partialResults, com.quartetfs.biz.pivot.cellset.IPostProcessedRetrievalResultWriter writer)
protected Collection<com.quartetfs.biz.pivot.ILocation>	sesPrefetcherComputeLocations(com.quartetfs.biz.pivot.ILocation location)
void	setPartitioningLevels(com.quartetfs.biz.pivot.ILocation location, Collection<com.quartetfs.biz.pivot.cube.hierarchy.ILevelInfo> partitioningLevels)
void	setPartitioningManagerFactory(IPostProcessorPartitioningManager.Factory partitioningManagerFactory)

Methods inherited from class com.quartetfs.biz.pivot.postprocessing.impl.AAdvancedPostProcessor

addContextDependency, checkInterruption, checkOutputType, computeOutputType, createEvaluator, expandResult, getActivePivot, getContext, getContextDependencies, getContinuousQueryHandlerKeys, getCurrentMeasure, getDatastoreVersion, getDerivedContextDependencies, getExpansionProcedure, getGenericOutputType, getMeasuresProvider, getName, getOutputType, getOutputTypeFromGenericClassParameter, getOutputTypeFromProperties, getPrefetchers, getProperties, getQueryCache, getTypeFromClass, handleCircularDependency, handleNotSupportedAnalysisLevels, handleUnknownUnderlyingMeasure, hideEvaluator, initializeContinuousQueryHandlerKeys, initializeUnderlyingMeasures, removeAnalysisLevelsFromFilter, restrictLocationAnalysisLevels, retrieveAnalysisLevelsToExpand, retrieveNamedPrefetchAggregatesWithAnalysisLevels, retrievePrefetchAggregates, retrievePrefetchAggregatesWithAnalysisLevels, setAggregatedMeasureName, supportsAnalysisLevels, toString

Methods inherited from class java.lang.Object

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

Methods inherited from interface com.quartetfs.biz.pivot.postprocessing.IPostProcessor

getContextDependencies, getContinuousQueryHandlerKeys, getName, getOutputType, getPrefetchers, getProperties, isPartitionedOnRangeLevelsFromProperties

Field Detail

PLUGIN_KEY

public static final String PLUGIN_KEY

See Also:

Constant Field Values

ISES_PREFETCHER_NAME

public static String ISES_PREFETCHER_NAME

SES_PREFETCHER_NAME

public static String SES_PREFETCHER_NAME

RHO_PROPERTY

public static final String RHO_PROPERTY

See Also:

Constant Field Values

DEFAULT_RHO

public static final double DEFAULT_RHO

See Also:

Constant Field Values

rho

protected Double rho

riskFactorLevel

protected com.quartetfs.biz.pivot.cube.hierarchy.ILevelInfo riskFactorLevel

riskClassLevel

protected com.quartetfs.biz.pivot.cube.hierarchy.ILevelInfo riskClassLevel

aggregationFunction

protected com.qfs.agg.IAggregationFunction aggregationFunction

partitioningManagerFactory

protected IPostProcessorPartitioningManager.Factory partitioningManagerFactory

partitioningManager

protected IPostProcessorPartitioningManager partitioningManager

Constructor Detail

SES

public SES(String name,
           com.quartetfs.biz.pivot.cube.hierarchy.measures.IPostProcessorCreationContext creationContext)

Method Detail

setPartitioningManagerFactory

public void setPartitioningManagerFactory(IPostProcessorPartitioningManager.Factory partitioningManagerFactory)

Specified by:

setPartitioningManagerFactory in interface IPostProcessorPartitioningManagerAware

getType

public String getType()

Specified by:

getType in interface com.quartetfs.fwk.types.IExtendedPluginValue

init

public void init(Properties properties)
          throws com.quartetfs.fwk.QuartetException

Specified by:

init in interface com.quartetfs.biz.pivot.postprocessing.IPostProcessor<Double>

Overrides:

init in class com.quartetfs.biz.pivot.postprocessing.impl.AAdvancedPostProcessor<Double>

Throws:

com.quartetfs.fwk.QuartetException

setPartitioningLevels

public void setPartitioningLevels(com.quartetfs.biz.pivot.ILocation location,
                                  Collection<com.quartetfs.biz.pivot.cube.hierarchy.ILevelInfo> partitioningLevels)

Specified by:

setPartitioningLevels in interface com.quartetfs.biz.pivot.postprocessing.IPartitionedPostProcessor<Double>

Specified by:

setPartitioningLevels in interface com.quartetfs.biz.pivot.postprocessing.IPostProcessor<Double>

getPostProcessorDescription

public static com.quartetfs.biz.pivot.definitions.IPostProcessorDescription getPostProcessorDescription(Properties env,
                                                                                                        String measureName,
                                                                                                        String esSesMeasure,
                                                                                                        String esISesMeasure,
                                                                                                        String folder,
                                                                                                        boolean visible)

Constructs the postprocessor definition

Parameters:

env - The properties to help construct the definition

measureName - The name of the measure

esSesMeasure - The ES SES measure

esISesMeasure - The ES ISES measure

folder - The folder to put this measure in

visible - The visibility of this measure

Returns:

The postprocessor definition

getRho

protected double getRho()

The value of parameter rho in the SES calculation. Priorities are:

1. "rho" post-processor initialization property
2. IRhoSesContextVal context value
3. default value: 0.6

Returns:

the value of rho

reduce

public void reduce(com.quartetfs.biz.pivot.ILocation location,
                   List<com.quartetfs.biz.pivot.cellset.IAggregatesRetrievalResult> partialResults,
                   com.quartetfs.biz.pivot.cellset.IPostProcessedRetrievalResultWriter writer)

Specified by:

reduce in interface com.quartetfs.biz.pivot.postprocessing.IPartitionedPostProcessor<Double>

levels

protected Map<com.quartetfs.biz.pivot.cube.hierarchy.IHierarchyInfo,com.quartetfs.biz.pivot.cube.hierarchy.ILevelInfo> levels(String seperator,
                                                                                                                              String description)
                                                                                                                       throws com.quartetfs.fwk.QuartetException

Throws:

com.quartetfs.fwk.QuartetException

hierarchies

protected List<com.quartetfs.biz.pivot.cube.hierarchy.IHierarchyInfo> hierarchies(String seperator,
                                                                                  String description)
                                                                           throws com.quartetfs.fwk.QuartetException

Throws:

com.quartetfs.fwk.QuartetException

compute

public void compute(com.quartetfs.biz.pivot.ILocation location,
                    com.quartetfs.biz.pivot.query.aggregates.IAdvancedAggregatesRetriever retriever)
             throws com.quartetfs.fwk.QuartetException

Specified by:

compute in interface com.quartetfs.biz.pivot.postprocessing.IPostProcessor<Double>

Throws:

com.quartetfs.fwk.QuartetException

calculateSES

public static Double calculateSES(double rho,
                                  Double sesSum,
                                  Double sesSumSq,
                                  Map<String,Double> isesSumSq)

calculateSES

public static Double calculateSES(double rho,
                                  double sesSum,
                                  double sesSumSq,
                                  Map<String,Double> isesSumSq)

sesPrefetcherComputeLocations

protected Collection<com.quartetfs.biz.pivot.ILocation> sesPrefetcherComputeLocations(com.quartetfs.biz.pivot.ILocation location)

createSESPrefetcher

protected com.quartetfs.biz.pivot.postprocessing.IPrefetcher<Void> createSESPrefetcher()

isesPrefetcherComputeLocations

protected Collection<com.quartetfs.biz.pivot.ILocation> isesPrefetcherComputeLocations(com.quartetfs.biz.pivot.ILocation location)

createISESPrefetcher

protected com.quartetfs.biz.pivot.postprocessing.IPrefetcher<Void> createISESPrefetcher()