Package org.rumbledb.spark.ml

Class RumbleMLUtils

java.lang.Object

org.rumbledb.spark.ml.RumbleMLUtils

public class RumbleMLUtils
extends Object

Constructor Summary

Constructors

Constructor	Description
RumbleMLUtils()

Method Summary

Modifier and Type	Method	Description
static Object	convertParamItemToJava(String paramName, Item param, String paramJavaTypeName, ExceptionMetadata metadata)
static org.apache.spark.ml.param.ParamMap	convertRumbleObjectItemToSparkMLParamMap(String estimatorShortName, org.apache.spark.ml.Estimator<?> estimator, Item paramMapItem, ExceptionMetadata metadata)
static org.apache.spark.ml.param.ParamMap	convertRumbleObjectItemToSparkMLParamMap(String transformerShortName, org.apache.spark.ml.Transformer transformer, Item paramMapItem, ExceptionMetadata metadata)
static RuntimeDataFrame<Item>	createDataFrameContainingVectorizedColumn(RuntimeDataFrame<Item> inputDataset, String paramNameExposedToTheUser, String[] arrayOfInputColumnNames, String outputColumnName, ExceptionMetadata metadata)
static RuntimeDataFrame<Item>	getDataFrameOrInferFromVariable(DynamicContext context, Name inputVariableName, RuntimeStaticContext staticContext, ExceptionMetadata metadata)
static Item	removeParameter(Item paramMapItem, String key, ExceptionMetadata metadata)

Methods inherited from class java.lang.Object

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

Constructor Details

RumbleMLUtils

public RumbleMLUtils()

Method Details

getDataFrameOrInferFromVariable

public static RuntimeDataFrame<Item> getDataFrameOrInferFromVariable(DynamicContext context,
 Name inputVariableName,
 RuntimeStaticContext staticContext,
 ExceptionMetadata metadata)

convertRumbleObjectItemToSparkMLParamMap

public static org.apache.spark.ml.param.ParamMap convertRumbleObjectItemToSparkMLParamMap(String transformerShortName,
 org.apache.spark.ml.Transformer transformer,
 Item paramMapItem,
 ExceptionMetadata metadata)

convertRumbleObjectItemToSparkMLParamMap

public static org.apache.spark.ml.param.ParamMap convertRumbleObjectItemToSparkMLParamMap(String estimatorShortName,
 org.apache.spark.ml.Estimator<?> estimator,
 Item paramMapItem,
 ExceptionMetadata metadata)

convertParamItemToJava

public static Object convertParamItemToJava(String paramName,
 Item param,
 String paramJavaTypeName,
 ExceptionMetadata metadata)

removeParameter

public static Item removeParameter(Item paramMapItem,
 String key,
 ExceptionMetadata metadata)

createDataFrameContainingVectorizedColumn

public static RuntimeDataFrame<Item> createDataFrameContainingVectorizedColumn(RuntimeDataFrame<Item> inputDataset,
 String paramNameExposedToTheUser,
 String[] arrayOfInputColumnNames,
 String outputColumnName,
 ExceptionMetadata metadata)