class SumPoolingAggregate extends AggregationWithDeaggBase

SUM_POOLING aggregation implementation.

Linear Supertypes
AggregationWithDeaggBase, AggregationSpec, Serializable, Serializable, AnyRef, Any
Known Subclasses
AvgPoolingAggregate
Ordering
  1. Alphabetic
  2. By Inheritance
Inherited
  1. SumPoolingAggregate
  2. AggregationWithDeaggBase
  3. AggregationSpec
  4. Serializable
  5. Serializable
  6. AnyRef
  7. Any
  1. Hide All
  2. Show All
Visibility
  1. Public
  2. All

Instance Constructors

  1. new SumPoolingAggregate(valueCol: String, countCol: String = "1")

    valueCol

    Name of the metric column or a Spark SQL column expression for derived metric that will be aggregated using SUM_POOLING. This operation differs from SUM in that this applies the SUM operation across an entire Seq of Numerics instead of a single value

    countCol

    Name of the column that keeps track of the count which is required for all aggregation functions that support deagg in order to identify when all records have been deagged out. This is needed for pre-aggregated fact dataset. For non-aggregated dataset, if the column name is not provided, use the default column expression lit(1).

Value Members

  1. final def !=(arg0: Any): Boolean
    Definition Classes
    AnyRef → Any
  2. final def ##(): Int
    Definition Classes
    AnyRef → Any
  3. final def ==(arg0: Any): Boolean
    Definition Classes
    AnyRef → Any
  4. val CountAggregate: CountAggregate
    Definition Classes
    AggregationWithDeaggBase
  5. def agg(aggregate: Any, record: Any, dataType: DataType): Any
    Definition Classes
    AggregationWithDeaggBase → AggregationSpec
  6. def aggValue(aggregate: Any, valueRecord: Any, valueDataType: DataType): Any

    Analogous to AggregationSpec.agg(), we aggregate the parsed value record to the intermediate aggregate value

    Analogous to AggregationSpec.agg(), we aggregate the parsed value record to the intermediate aggregate value

    aggregate

    The intermediate aggregate value

    valueRecord

    Parsed value record to aggregate

    valueDataType

    The value record datatype

    returns

    The result of aggregating the value record to the intermediate aggregate value

    Definition Classes
    SumPoolingAggregate → AggregationWithDeaggBase
  7. def aggregation: AggregationType

    <invalid inheritdoc annotation>

    <invalid inheritdoc annotation>

    Definition Classes
    SumPoolingAggregate → AggregationWithDeaggBase → AggregationSpec
  8. final def asInstanceOf[T0]: T0
    Definition Classes
    Any
  9. def calculateAggregate(aggregate: Any, dataType: DataType): Any
    Definition Classes
    AggregationWithDeaggBase → AggregationSpec
  10. def calculateAggregateWithCount(aggregate: Any, valueDataType: DataType, count: Any, countDataType: DataType): Any

    Analogous to AggregationSpec.calculateAggregate(), perform an additional step to calculate the final aggregate value.

    Analogous to AggregationSpec.calculateAggregate(), perform an additional step to calculate the final aggregate value. This method has access to the current running count if needed for the calculation (e.g. AVG). Default implementation is to return the aggregate value as is.

    aggregate

    The intermediate aggregate value

    valueDataType

    The value record datatype

    count

    The intermediate count value

    countDataType

    The count record datatype

    returns

    The calculated aggregate value

    Definition Classes
    SumPoolingAggregate → AggregationWithDeaggBase
  11. def clone(): AnyRef
    Attributes
    protected[lang]
    Definition Classes
    AnyRef
    Annotations
    @throws( ... ) @native()
  12. val countCol: String

    Name of the column that keeps track of the count which is required for all aggregation functions that support deagg in order to identify when all records have been deagged out

    Name of the column that keeps track of the count which is required for all aggregation functions that support deagg in order to identify when all records have been deagged out

    Definition Classes
    SumPoolingAggregate → AggregationWithDeaggBase
  13. def deagg(aggregate: Any, record: Any, dataType: DataType): Any
    Definition Classes
    AggregationWithDeaggBase → AggregationSpec
  14. def deaggValue(aggregate: Any, valueRecord: Any, valueDataType: DataType): Any

    Analogous to AggregationSpec.deagg(), we deagg the parsed value record from the intermediate aggregate value

    Analogous to AggregationSpec.deagg(), we deagg the parsed value record from the intermediate aggregate value

    aggregate

    The intermediate aggregate value

    valueRecord

    Parsed value record to deagg

    valueDataType

    The value record datatype

    returns

    The result of deagging the value record from the intermediate aggregate value

    Definition Classes
    SumPoolingAggregate → AggregationWithDeaggBase
  15. final def eq(arg0: AnyRef): Boolean
    Definition Classes
    AnyRef
  16. def equals(arg0: Any): Boolean
    Definition Classes
    AnyRef → Any
  17. def finalize(): Unit
    Attributes
    protected[lang]
    Definition Classes
    AnyRef
    Annotations
    @throws( classOf[java.lang.Throwable] )
  18. final def getClass(): Class[_]
    Definition Classes
    AnyRef → Any
    Annotations
    @native()
  19. def hashCode(): Int
    Definition Classes
    AnyRef → Any
    Annotations
    @native()
  20. def isCalculateAggregateNeeded: Boolean
    Definition Classes
    SumPoolingAggregate → AggregationSpec
  21. def isIncrementalAgg: Boolean
    Definition Classes
    AggregationWithDeaggBase → AggregationSpec
  22. final def isInstanceOf[T0]: Boolean
    Definition Classes
    Any
  23. def metricCol: String
    Definition Classes
    AggregationWithDeaggBase → AggregationSpec
  24. def metricName: String

    <invalid inheritdoc annotation>

    <invalid inheritdoc annotation>

    Definition Classes
    SumPoolingAggregate → AggregationWithDeaggBase → AggregationSpec
  25. final def ne(arg0: AnyRef): Boolean
    Definition Classes
    AnyRef
  26. final def notify(): Unit
    Definition Classes
    AnyRef
    Annotations
    @native()
  27. final def notifyAll(): Unit
    Definition Classes
    AnyRef
    Annotations
    @native()
  28. final def synchronized[T0](arg0: ⇒ T0): T0
    Definition Classes
    AnyRef
  29. def toString(): String
    Definition Classes
    AnyRef → Any
  30. def updateAggDataType(featureColumnMetaData: FeatureColumnMetaData): Unit
    Definition Classes
    AggregationWithDeaggBase → AggregationSpec
  31. val valueCol: String

    Name of the metric column or a Spark SQL column expression for derived metric that will be aggregated

    Name of the metric column or a Spark SQL column expression for derived metric that will be aggregated

    Definition Classes
    SumPoolingAggregate → AggregationWithDeaggBase
  32. final def wait(): Unit
    Definition Classes
    AnyRef
    Annotations
    @throws( ... )
  33. final def wait(arg0: Long, arg1: Int): Unit
    Definition Classes
    AnyRef
    Annotations
    @throws( ... )
  34. final def wait(arg0: Long): Unit
    Definition Classes
    AnyRef
    Annotations
    @throws( ... ) @native()

Inherited from AggregationWithDeaggBase

Inherited from AggregationSpec

Inherited from Serializable

Inherited from Serializable

Inherited from AnyRef

Inherited from Any

Ungrouped