org.locationtech.geowave.analytic.spark.kmeans

Class KMeansRunner

java.lang.Object

org.locationtech.geowave.analytic.spark.kmeans.KMeansRunner

public class KMeansRunner
extends Object

Constructor Summary

Constructors

Constructor and Description
KMeansRunner()

Method Summary

Modifier and Type	Method and Description
void	close()
String	getCentroidTypeName()
String	getHullTypeName()
org.apache.spark.api.java.JavaRDD<org.apache.spark.mllib.linalg.Vector>	getInputCentroids()
DataStorePluginOptions	getInputDataStore()
DataStorePluginOptions	getOutputDataStore()
org.apache.spark.mllib.clustering.KMeansModel	getOutputModel()
Boolean	isComputeHullData()
Boolean	isGenerateHulls()
Boolean	isUseTime()
void	run()
void	setAppName(String appName)
void	setCentroidTypeName(String centroidTypeName)
void	setComputeHullData(Boolean computeHullData)
void	setCqlFilter(String cqlFilter)
void	setEpsilon(Double epsilon)
void	setGenerateHulls(Boolean generateHulls)
void	setHost(String host)
void	setHullTypeName(String hullTypeName)
void	setInputDataStore(DataStorePluginOptions inputDataStore)
void	setMaster(String master)
void	setNumClusters(int numClusters)
void	setNumIterations(int numIterations)
void	setOutputDataStore(DataStorePluginOptions outputDataStore)
void	setSparkSession(org.apache.spark.sql.SparkSession ss)
void	setSplits(int min, int max)
void	setTimeParams(String timeField, ScaledTemporalRange timeRange)
void	setTypeName(String typeName)
void	setUseTime(Boolean useTime)
void	writeToOutputStore()

Methods inherited from class java.lang.Object

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

Constructor Detail

KMeansRunner

public KMeansRunner()

Method Detail

close

public void close()

run

public void run()
         throws IOException

Throws:

IOException

writeToOutputStore

public void writeToOutputStore()

isUseTime

public Boolean isUseTime()

setUseTime

public void setUseTime(Boolean useTime)

getCentroidTypeName

public String getCentroidTypeName()

setCentroidTypeName

public void setCentroidTypeName(String centroidTypeName)

getHullTypeName

public String getHullTypeName()

setHullTypeName

public void setHullTypeName(String hullTypeName)

isGenerateHulls

public Boolean isGenerateHulls()

setGenerateHulls

public void setGenerateHulls(Boolean generateHulls)

isComputeHullData

public Boolean isComputeHullData()

setComputeHullData

public void setComputeHullData(Boolean computeHullData)

getInputCentroids

public org.apache.spark.api.java.JavaRDD<org.apache.spark.mllib.linalg.Vector> getInputCentroids()

getInputDataStore

public DataStorePluginOptions getInputDataStore()

setInputDataStore

public void setInputDataStore(DataStorePluginOptions inputDataStore)

getOutputDataStore

public DataStorePluginOptions getOutputDataStore()

setOutputDataStore

public void setOutputDataStore(DataStorePluginOptions outputDataStore)

setSparkSession

public void setSparkSession(org.apache.spark.sql.SparkSession ss)

setNumClusters

public void setNumClusters(int numClusters)

setNumIterations

public void setNumIterations(int numIterations)

setEpsilon

public void setEpsilon(Double epsilon)

getOutputModel

public org.apache.spark.mllib.clustering.KMeansModel getOutputModel()

setAppName

public void setAppName(String appName)

setMaster

public void setMaster(String master)

setHost

public void setHost(String host)

setCqlFilter

public void setCqlFilter(String cqlFilter)

setTypeName

public void setTypeName(String typeName)

setTimeParams

public void setTimeParams(String timeField,
                          ScaledTemporalRange timeRange)

setSplits

public void setSplits(int min,
                      int max)