Package com.dataai.etl.spark.functions

Class MatrixFunctions

java.lang.Object

com.dataai.etl.spark.functions.MatrixFunctions

public final class MatrixFunctions
extends Object

Method Summary

Modifier and Type	Method	Description
static MatrixBalanceResult	balance(org.apache.spark.sql.Dataset<org.apache.spark.sql.Row> input, String rowField, String columnField, String valueField, org.apache.spark.sql.Dataset<org.apache.spark.sql.Row> rowTargets, org.apache.spark.sql.Dataset<org.apache.spark.sql.Row> columnTargets, String targetColumn, int maximumIterations, double tolerance)
static org.apache.spark.sql.Dataset<org.apache.spark.sql.Row>	crossTab(org.apache.spark.sql.Dataset<org.apache.spark.sql.Row> input, String rowField, String columnField, String valueField, Aggregation aggregation)

Methods inherited from class java.lang.Object

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

Method Details

crossTab

public static org.apache.spark.sql.Dataset<org.apache.spark.sql.Row> crossTab(org.apache.spark.sql.Dataset<org.apache.spark.sql.Row> input,
 String rowField,
 String columnField,
 String valueField,
 Aggregation aggregation)

balance

public static MatrixBalanceResult balance(org.apache.spark.sql.Dataset<org.apache.spark.sql.Row> input,
 String rowField,
 String columnField,
 String valueField,
 org.apache.spark.sql.Dataset<org.apache.spark.sql.Row> rowTargets,
 org.apache.spark.sql.Dataset<org.apache.spark.sql.Row> columnTargets,
 String targetColumn,
 int maximumIterations,
 double tolerance)