co.cask.cdap.data2.dataset2.lib.cube

Class DefaultAggregation

java.lang.Object

co.cask.cdap.data2.dataset2.lib.cube.DefaultAggregation

All Implemented Interfaces:

Aggregation

public class DefaultAggregation
extends Object
implements Aggregation

Default implementation of Aggregation.

Constructor Summary

Constructors

Constructor and Description
DefaultAggregation(List<String> aggregateDimensions) Creates instance of DefaultAggregation with all tags being optional.
DefaultAggregation(List<String> aggregateDimensions, Collection<String> requiredDimensions) Creates instance of DefaultAggregation.

Method Summary

Methods

Modifier and Type	Method and Description
boolean	accept(co.cask.cdap.api.dataset.lib.cube.CubeFact fact) Filters out CubeFacts which should not be added into this aggregation.
List<String>	getDimensionNames() Defines the dimensions to do the aggregation for.
Set<String>	getRequiredDimensions()

Methods inherited from class java.lang.Object

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

Constructor Detail

DefaultAggregation

public DefaultAggregation(List<String> aggregateDimensions)

Creates instance of DefaultAggregation with all tags being optional.

Parameters:

aggregateDimensions - tags to be included in aggregation.

DefaultAggregation

public DefaultAggregation(List<String> aggregateDimensions,
                  Collection<String> requiredDimensions)

Creates instance of DefaultAggregation.

See also Aggregation.getDimensionNames() for more info on aggregateDimensions.

Parameters:

aggregateDimensions - dimensions to be included in aggregation.

requiredDimensions - dimensions that must be present in CubeFact for aggregated value to be stored.

Method Detail

getDimensionNames

public List<String> getDimensionNames()

Description copied from interface: Aggregation

Defines the dimensions to do the aggregation for.

Depending on the implementation of a Cube, the order of the dimension names can be used as is to form a row key. That in turn may affect the performance of the querying. Usually you want to put most frequently defined dimensions (dimensions with values to slice by in CubeQuery to be in front.

Specified by:

getDimensionNames in interface Aggregation

Returns:

list of dimensions (dimensions) to aggregate by

getRequiredDimensions

public Set<String> getRequiredDimensions()

accept

public boolean accept(co.cask.cdap.api.dataset.lib.cube.CubeFact fact)

Description copied from interface: Aggregation

Filters out CubeFacts which should not be added into this aggregation.

Specified by:

accept in interface Aggregation

Parameters:

fact - fact to test

Returns:

true if fact should be added to the aggregation, false otherwise.