package aggregate
- Alphabetic
- Public
- All
Type Members
-
abstract
class
AggregationWithDeaggBase extends AggregationSpec
Base class for aggregation functions that support the deagg operation (e.g.
Base class for aggregation functions that support the deagg operation (e.g. Sum/Avg). This class provides common functionality to keep track of a running count aggregation while performing the implemented aggregation type. Keeping track of the running count is important in order to identify when all records have been deagged out so the aggregate value can be properly reset. This is important to maintain current expectation where aggregate value is null when there are no records to aggregate together and to prevent floating point rounding errors causing the deagged aggregate value to be infinitesimally small instead of equal to zero. This class abstracts way the management of the count aggregation column so child classes only have to worry about implementing the aggregation function for the value column.
-
class
AvgAggregate extends AggregationSpec
AVG aggregation implementation.
-
class
AvgPoolingAggregate extends SumPoolingAggregate
AVG_POOLING aggregation implementation.
-
class
CountAggregate extends AggregationSpec
COUNT aggregation implementation.
-
class
CountDistinctAggregate extends AggregationSpec
COUNT_DISTINCT aggregation implementation.
-
class
DummyAggregate extends AggregationSpec
Dummy aggregation.
Dummy aggregation. To be used as placeholder for operations not implemented in SWJ library yet.
-
class
LatestAggregate extends AggregationSpec
LATEST aggregation implementation
-
class
MaxAggregate extends AggregationSpec
MAX aggregation implementation.
-
class
MaxPoolingAggregate extends AggregationSpec
MAX_POOLING aggregation implementation.
-
class
MinAggregate extends AggregationSpec
MIM aggregation implementation.
-
class
MinPoolingAggregate extends AggregationSpec
MIN_POOLING aggregation implementation.
-
class
SumAggregate extends AggregationSpec
SUM aggregation implementation
-
class
SumPoolingAggregate extends AggregationWithDeaggBase
SUM_POOLING aggregation implementation.
-
class
TimesinceAggregate extends AggregationSpec
TIMESINCE aggregation implementation
Value Members
- object AggregationType extends Enumeration
- object AvgPoolingAggregate extends Serializable
- object MaxPoolingAggregate extends Serializable
- object MinPoolingAggregate extends Serializable
- object SumPoolingAggregate extends Serializable