org.locationtech.geowave.analytic.clustering

Class NestedGroupCentroidAssignment<T>

java.lang.Object

org.locationtech.geowave.analytic.clustering.NestedGroupCentroidAssignment<T>

Type Parameters:

T -

public class NestedGroupCentroidAssignment<T>
extends Object

A helper class that finds the closest centroid to a point at a specific zoom level.

If the starting level does match the specified level, then the centroid tree is 'walked' down. Walking up to higher levels is not supported.

Levels are number 1 to n where 1 is the top tier. The current tier being computed may have a different batch ID (temporary) than all upper level tiers. In this case, a parent batch id is provided to resolve groups for those tiers. This approach is often used in speculative computation at each tier.

Parameters include:

"NestedGroupCentroidAssignment.Global.ParentBatchId" -> Parent Tier Batch IDs. If not present then assume value NestedGroupCentroidAssignment.Global.BatchId

"NestedGroupCentroidAssignment.Global.BatchId" -> batch id for current tier.

"NestedGroupCentroidAssignment.Global.ZoomLevel" -> current tier (level)

"NestedGroupCentroidAssignment.Common.DistanceFunctionClass" -> distance function used for association of data points to centroid.

See Also:

Constructor Summary

Constructors

Constructor and Description
NestedGroupCentroidAssignment(CentroidManager<T> centroidManager, int endZoomLevel, String parentBatchID, DistanceFn<T> distanceFunction)
NestedGroupCentroidAssignment(org.apache.hadoop.mapreduce.JobContext context, Class<?> scope, org.slf4j.Logger logger)

Method Summary

Modifier and Type	Method and Description
double	findCentroidForLevel(AnalyticItemWrapper<T> item, AssociationNotification<T> associationNotification)
List<AnalyticItemWrapper<T>>	getCentroidsForGroup(String groupID)
String	getGroupForLevel(AnalyticItemWrapper<T> item) Get the associated group id from the current zoom level
static Collection<ParameterEnum<?>>	getParameters()
static void	setParameters(org.apache.hadoop.conf.Configuration config, Class<?> scope, PropertyManagement runTimeProperties)
static void	setParentBatchID(org.apache.hadoop.conf.Configuration config, Class<?> scope, String parentID) Override parent batch ID from parameters
static void	setZoomLevel(org.apache.hadoop.conf.Configuration config, Class<?> scope, int zoomLevel) Override zoomLevel from parameters

Methods inherited from class java.lang.Object

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

Constructor Detail

NestedGroupCentroidAssignment

public NestedGroupCentroidAssignment(CentroidManager<T> centroidManager,
                                     int endZoomLevel,
                                     String parentBatchID,
                                     DistanceFn<T> distanceFunction)

NestedGroupCentroidAssignment

public NestedGroupCentroidAssignment(org.apache.hadoop.mapreduce.JobContext context,
                                     Class<?> scope,
                                     org.slf4j.Logger logger)
                              throws InstantiationException,
                                     IllegalAccessException,
                                     IOException

Throws:

InstantiationException

IllegalAccessException

IOException

Method Detail

setZoomLevel

public static void setZoomLevel(org.apache.hadoop.conf.Configuration config,
                                Class<?> scope,
                                int zoomLevel)

Override zoomLevel from parameters

setParentBatchID

public static void setParentBatchID(org.apache.hadoop.conf.Configuration config,
                                    Class<?> scope,
                                    String parentID)

Override parent batch ID from parameters

getParameters

public static Collection<ParameterEnum<?>> getParameters()

getCentroidsForGroup

public List<AnalyticItemWrapper<T>> getCentroidsForGroup(String groupID)
                                                  throws IOException

Throws:

IOException

getGroupForLevel

public String getGroupForLevel(AnalyticItemWrapper<T> item)
                        throws IOException

Get the associated group id from the current zoom level

Throws:

IOException

findCentroidForLevel

public double findCentroidForLevel(AnalyticItemWrapper<T> item,
                                   AssociationNotification<T> associationNotification)
                            throws IOException

Throws:

IOException

setParameters

public static void setParameters(org.apache.hadoop.conf.Configuration config,
                                 Class<?> scope,
                                 PropertyManagement runTimeProperties)