Package com.dataai.etl.spark.functions

Class MarketFunctions

java.lang.Object

com.dataai.etl.spark.functions.MarketFunctions

public final class MarketFunctions
extends Object

Method Summary

Modifier and Type	Method	Description
static org.apache.spark.sql.Dataset<org.apache.spark.sql.Row>	basket(org.apache.spark.sql.Dataset<org.apache.spark.sql.Row> input, String transactionField, String itemField, String valueField)
static org.apache.spark.sql.Dataset<org.apache.spark.sql.Row>	churn(org.apache.spark.sql.Dataset<org.apache.spark.sql.Row> input, String customerField, String valueField, String activityDateField, int activeDays, int reviewDays)
static org.apache.spark.sql.Dataset<org.apache.spark.sql.Row>	demand(org.apache.spark.sql.Dataset<org.apache.spark.sql.Row> input, List<String> dimensionFields, String valueField, String dateField, TimePeriod period, double assumptionPercent)
static org.apache.spark.sql.Dataset<org.apache.spark.sql.Row>	elasticity(org.apache.spark.sql.Dataset<org.apache.spark.sql.Row> input, String dimensionField, String priceField, String quantityField, int numberOfBands, double priceChangeAssumptionPercent)
static org.apache.spark.sql.Dataset<org.apache.spark.sql.Row>	inventory(org.apache.spark.sql.Dataset<org.apache.spark.sql.Row> input, List<String> dimensionFields, String movementField, String currentInventoryField, double safetyStockPercent)
static org.apache.spark.sql.Dataset<org.apache.spark.sql.Row>	pricing(org.apache.spark.sql.Dataset<org.apache.spark.sql.Row> input, String dimensionField, String priceField, String quantityField, int numberOfBands)
static org.apache.spark.sql.Dataset<org.apache.spark.sql.Row>	profit(org.apache.spark.sql.Dataset<org.apache.spark.sql.Row> input, List<String> dimensionFields, String revenueField, String directCostField, String unitCostField, String quantityField, double estimatedCostPercent)
static org.apache.spark.sql.Dataset<org.apache.spark.sql.Row>	risk(org.apache.spark.sql.Dataset<org.apache.spark.sql.Row> input, List<String> dimensionFields, String exposureField)
static org.apache.spark.sql.Dataset<org.apache.spark.sql.Row>	scenario(org.apache.spark.sql.Dataset<org.apache.spark.sql.Row> input, List<String> dimensionFields, String valueField, double assumptionPercent)
static org.apache.spark.sql.Dataset<org.apache.spark.sql.Row>	segments(org.apache.spark.sql.Dataset<org.apache.spark.sql.Row> input, List<String> dimensionFields, String valueField)

Methods inherited from class java.lang.Object

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

Method Details

demand

public static org.apache.spark.sql.Dataset<org.apache.spark.sql.Row> demand(org.apache.spark.sql.Dataset<org.apache.spark.sql.Row> input,
 List<String> dimensionFields,
 String valueField,
 String dateField,
 TimePeriod period,
 double assumptionPercent)

segments

public static org.apache.spark.sql.Dataset<org.apache.spark.sql.Row> segments(org.apache.spark.sql.Dataset<org.apache.spark.sql.Row> input,
 List<String> dimensionFields,
 String valueField)

risk

public static org.apache.spark.sql.Dataset<org.apache.spark.sql.Row> risk(org.apache.spark.sql.Dataset<org.apache.spark.sql.Row> input,
 List<String> dimensionFields,
 String exposureField)

scenario

public static org.apache.spark.sql.Dataset<org.apache.spark.sql.Row> scenario(org.apache.spark.sql.Dataset<org.apache.spark.sql.Row> input,
 List<String> dimensionFields,
 String valueField,
 double assumptionPercent)

pricing

public static org.apache.spark.sql.Dataset<org.apache.spark.sql.Row> pricing(org.apache.spark.sql.Dataset<org.apache.spark.sql.Row> input,
 String dimensionField,
 String priceField,
 String quantityField,
 int numberOfBands)

elasticity

public static org.apache.spark.sql.Dataset<org.apache.spark.sql.Row> elasticity(org.apache.spark.sql.Dataset<org.apache.spark.sql.Row> input,
 String dimensionField,
 String priceField,
 String quantityField,
 int numberOfBands,
 double priceChangeAssumptionPercent)

basket

public static org.apache.spark.sql.Dataset<org.apache.spark.sql.Row> basket(org.apache.spark.sql.Dataset<org.apache.spark.sql.Row> input,
 String transactionField,
 String itemField,
 String valueField)

churn

public static org.apache.spark.sql.Dataset<org.apache.spark.sql.Row> churn(org.apache.spark.sql.Dataset<org.apache.spark.sql.Row> input,
 String customerField,
 String valueField,
 String activityDateField,
 int activeDays,
 int reviewDays)

inventory

public static org.apache.spark.sql.Dataset<org.apache.spark.sql.Row> inventory(org.apache.spark.sql.Dataset<org.apache.spark.sql.Row> input,
 List<String> dimensionFields,
 String movementField,
 String currentInventoryField,
 double safetyStockPercent)

profit

public static org.apache.spark.sql.Dataset<org.apache.spark.sql.Row> profit(org.apache.spark.sql.Dataset<org.apache.spark.sql.Row> input,
 List<String> dimensionFields,
 String revenueField,
 String directCostField,
 String unitCostField,
 String quantityField,
 double estimatedCostPercent)