org.locationtech.geowave.analytic.mapreduce.dbscan

Class DBScanIterationsJobRunner

java.lang.Object

org.locationtech.geowave.analytic.mapreduce.dbscan.DBScanIterationsJobRunner

All Implemented Interfaces:

IndependentJobRunner, MapReduceJobRunner

public class DBScanIterationsJobRunner
extends Object
implements MapReduceJobRunner, IndependentJobRunner

DBScan involves multiple iterations. The first iteration conceivably takes a set of points and produces small clusters (nearest neighbors). Each subsequent iteration merges clusters within a given distance from each other. This process can continue no new clusters are created (merges do not occur).

The first iteration places a constraint on the minimum number of neighbors. Subsequent iterations do not have a minimum, since each of the clusters is already vetted out by the first iteration.

Field Summary

Fields

Modifier and Type	Field and Description
protected FormatConfiguration	inputFormatConfiguration
protected static org.slf4j.Logger	LOGGER
protected int	zoomLevel

Constructor Summary

Constructors

Constructor and Description
DBScanIterationsJobRunner()

Method Summary

Modifier and Type	Method and Description
Collection<ParameterEnum<?>>	getParameters()
int	run(org.apache.hadoop.conf.Configuration config, PropertyManagement runTimeProperties)
int	run(PropertyManagement runTimeProperties)
void	setInputFormatConfiguration(FormatConfiguration inputFormatConfiguration)
void	setReducerCount(int reducerCount)
protected void	setZoomLevel(int zoomLevel)

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

inputFormatConfiguration

protected FormatConfiguration inputFormatConfiguration

zoomLevel

protected int zoomLevel

Constructor Detail

DBScanIterationsJobRunner

public DBScanIterationsJobRunner()

Method Detail

setInputFormatConfiguration

public void setInputFormatConfiguration(FormatConfiguration inputFormatConfiguration)

setReducerCount

public void setReducerCount(int reducerCount)

setZoomLevel

protected void setZoomLevel(int zoomLevel)

run

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

Specified by:

run in interface MapReduceJobRunner

Throws:

Exception

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