org.locationtech.geowave.analytic.mapreduce.kmeans.runner

Class KMeansIterationsJobRunner<T>

java.lang.Object

org.locationtech.geowave.analytic.mapreduce.kmeans.runner.KMeansIterationsJobRunner<T>

All Implemented Interfaces:

IndependentJobRunner, MapReduceJobRunner

public class KMeansIterationsJobRunner<T>
extends Object
implements MapReduceJobRunner, IndependentJobRunner

Run 'K' means until convergence across ALL groups.

Field Summary

Fields

Modifier and Type	Field and Description
protected static org.slf4j.Logger	LOGGER

Constructor Summary

Constructors

Constructor and Description
KMeansIterationsJobRunner()

Method Summary

Modifier and Type	Method and Description
protected int	computeCostAndCleanUp(String groupID, List<AnalyticItemWrapper<T>> centroids, CentroidManager<T> centroidManager, DistanceFn<T> distanceFunction)
protected CentroidManager<T>	constructCentroidManager(org.apache.hadoop.conf.Configuration config, PropertyManagement runTimeProperties)
Collection<ParameterEnum<?>>	getParameters()
int	run(org.apache.hadoop.conf.Configuration config, PropertyManagement runTimeProperties)
int	run(PropertyManagement runTimeProperties)
protected int	runJob(org.apache.hadoop.conf.Configuration config, PropertyManagement runTimeProperties)
void	setInputFormatConfiguration(FormatConfiguration inputFormatConfiguration)
void	setReducerCount(int reducerCount)

Methods inherited from class java.lang.Object

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

Field Detail

LOGGER

protected static final org.slf4j.Logger LOGGER

Constructor Detail

KMeansIterationsJobRunner

public KMeansIterationsJobRunner()

Method Detail

constructCentroidManager

protected CentroidManager<T> constructCentroidManager(org.apache.hadoop.conf.Configuration config,
                                                      PropertyManagement runTimeProperties)
                                               throws IOException

Throws:

IOException

setInputFormatConfiguration

public void setInputFormatConfiguration(FormatConfiguration inputFormatConfiguration)

setReducerCount

public void setReducerCount(int reducerCount)

run

public int run(org.apache.hadoop.conf.Configuration config,
               PropertyManagement runTimeProperties)
        throws Exception

Specified by:

run in interface MapReduceJobRunner

Throws:

Exception

runJob

protected int runJob(org.apache.hadoop.conf.Configuration config,
                     PropertyManagement runTimeProperties)
              throws Exception

Throws:

Exception

computeCostAndCleanUp

protected int computeCostAndCleanUp(String groupID,
                                    List<AnalyticItemWrapper<T>> centroids,
                                    CentroidManager<T> centroidManager,
                                    DistanceFn<T> distanceFunction)

getParameters

public Collection<ParameterEnum<?>> getParameters()

Specified by:

getParameters in interface IndependentJobRunner

run

public int run(PropertyManagement runTimeProperties)
        throws Exception

Specified by:

run in interface IndependentJobRunner

Throws:

Exception