Uses of Enum Class
com.dataai.etl.spark.functions.Aggregation

  • Uses of Aggregation in com.dataai.etl.spark.functions

    Methods in com.dataai.etl.spark.functions that return Aggregation
    Modifier and Type
    Method
    Description
    static Aggregation
    Aggregation.valueOf(String name)
    Returns the enum constant of this class with the specified name.
    static Aggregation[]
    Aggregation.values()
    Returns an array containing the constants of this enum class, in the order they are declared.
    Methods in com.dataai.etl.spark.functions with parameters of type Aggregation
    Modifier and Type
    Method
    Description
    static org.apache.spark.sql.Dataset<org.apache.spark.sql.Row>
    MatrixFunctions.crossTab(org.apache.spark.sql.Dataset<org.apache.spark.sql.Row> input, String rowField, String columnField, String valueField, Aggregation aggregation)
     
    static org.apache.spark.sql.Dataset<org.apache.spark.sql.Row>
    AnalyticsFunctions.groupedSummary(org.apache.spark.sql.Dataset<org.apache.spark.sql.Row> input, List<String> groupFields, String valueField, Aggregation aggregation)
     
    static org.apache.spark.sql.Dataset<org.apache.spark.sql.Row>
    BusinessFunctions.pareto(org.apache.spark.sql.Dataset<org.apache.spark.sql.Row> input, String dimensionField, String valueField, Aggregation aggregation)
     
    static org.apache.spark.sql.Dataset<org.apache.spark.sql.Row>
    AnalyticsFunctions.pivot(org.apache.spark.sql.Dataset<org.apache.spark.sql.Row> input, String rowField, String columnField, String valueField, Aggregation aggregation)
     
    static org.apache.spark.sql.Dataset<org.apache.spark.sql.Row>
    AnalyticsFunctions.ranking(org.apache.spark.sql.Dataset<org.apache.spark.sql.Row> input, String rankField, List<String> withinGroupFields, String valueField, Aggregation aggregation, RankMode mode, int limitPerGroup)
     
    static org.apache.spark.sql.Dataset<org.apache.spark.sql.Row>
    TimeSeriesFunctions.rolling(org.apache.spark.sql.Dataset<org.apache.spark.sql.Row> input, List<String> groupFields, String dateField, TimePeriod period, String valueField, Aggregation aggregation, int windowPeriods, RollingOperation operation)
     
    static org.apache.spark.sql.Dataset<org.apache.spark.sql.Row>
    TimeSeriesFunctions.summarize(org.apache.spark.sql.Dataset<org.apache.spark.sql.Row> input, List<String> groupFields, String dateField, TimePeriod period, String valueField, Aggregation aggregation)
     
    static org.apache.spark.sql.Dataset<org.apache.spark.sql.Row>
    AnalyticsFunctions.variance(org.apache.spark.sql.Dataset<org.apache.spark.sql.Row> input, List<String> groupFields, String compareField, String baseValue, String comparisonValue, String valueField, Aggregation aggregation)