org.apache.lens.ml.algo.spark

Class TableTrainingSpec

java.lang.Object

org.apache.lens.ml.algo.spark.TableTrainingSpec

All Implemented Interfaces:

Serializable

public class TableTrainingSpec
extends Object
implements Serializable

The Class TableTrainingSpec.

See Also:

Serialized Form

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static class	TableTrainingSpec.DataSample The Class DataSample.
static class	TableTrainingSpec.GetLabeledPoint The Class GetLabeledPoint.
static class	TableTrainingSpec.TableTrainingSpecBuilder The Class TableTrainingSpecBuilder.
static class	TableTrainingSpec.TestingFilter The Class TestingFilter.
static class	TableTrainingSpec.TrainingFilter The Class TrainingFilter.

Constructor Summary

Constructors

Constructor and Description
TableTrainingSpec()

Method Summary

Modifier and Type	Method and Description
void	createRDDs(org.apache.spark.api.java.JavaSparkContext sparkContext) Creates the rd ds.
org.apache.hadoop.hive.conf.HiveConf	getConf() The conf.
String	getDatabase() The database.
List<String>	getFeatureColumns() The feature columns.
String	getLabelColumn() The label column.
String	getPartitionFilter() The partition filter.
String	getTable() The table.
org.apache.spark.rdd.RDD<org.apache.spark.mllib.regression.LabeledPoint>	getTestingRDD() The testing rdd.
org.apache.spark.rdd.RDD<org.apache.spark.mllib.regression.LabeledPoint>	getTrainingRDD() The training rdd.
static TableTrainingSpec.TableTrainingSpecBuilder	newBuilder() New builder.
String	toString()

Methods inherited from class java.lang.Object

equals, getClass, hashCode, notify, notifyAll, wait, wait, wait

Constructor Detail

TableTrainingSpec

public TableTrainingSpec()

Method Detail

newBuilder

public static TableTrainingSpec.TableTrainingSpecBuilder newBuilder()

New builder.

Returns:

the table training spec builder

createRDDs

public void createRDDs(org.apache.spark.api.java.JavaSparkContext sparkContext)
                throws LensException

Creates the rd ds.

Parameters:

sparkContext - the spark context

Throws:

LensException - the lens exception

toString

@Generated(value="lombok")
public String toString()

Overrides:

toString in class Object

getTrainingRDD

@Generated(value="lombok")
public org.apache.spark.rdd.RDD<org.apache.spark.mllib.regression.LabeledPoint> getTrainingRDD()

The training rdd.

getTestingRDD

@Generated(value="lombok")
public org.apache.spark.rdd.RDD<org.apache.spark.mllib.regression.LabeledPoint> getTestingRDD()

The testing rdd.

getDatabase

@Generated(value="lombok")
public String getDatabase()

The database.

getTable

@Generated(value="lombok")
public String getTable()

The table.

getPartitionFilter

@Generated(value="lombok")
public String getPartitionFilter()

The partition filter.

getFeatureColumns

@Generated(value="lombok")
public List<String> getFeatureColumns()

The feature columns.

getLabelColumn

@Generated(value="lombok")
public String getLabelColumn()

The label column.

getConf

@Generated(value="lombok")
public org.apache.hadoop.hive.conf.HiveConf getConf()

The conf.