org.locationtech.geowave.analytic.partitioner

Interface Partitioner<T>

Type Parameters:

T -

All Superinterfaces:

Serializable

All Known Implementing Classes:

AbstractPartitioner, BoundaryPartitioner, NNMapReduce.PassthruPartitioner, OrthodromicDistancePartitioner

public interface Partitioner<T>
extends Serializable

Provide a partition for a data item.

Multiple partitions are permitted. Only one partition is consider primary. A primary partition is the partition for an item in which the item is processed on behalf of itself. All other partitions are those partitions that require visibility to the a specific item for other items to reference. This approach supports nearest neighbor type queries. Consider that an item can only discover neighbors in its partition. However, the item can be discovered as a nearest neighbor in those partitions in which the item participates as a none primary.

Nested Class Summary

Nested Classes

Modifier and Type	Interface and Description
static class	Partitioner.PartitionData Represents a partition associated with a specific item.
static interface	Partitioner.PartitionDataCallback

Method Summary

Modifier and Type	Method and Description
List<Partitioner.PartitionData>	getCubeIdentifiers(T entry)
Collection<ParameterEnum<?>>	getParameters()
void	initialize(org.apache.hadoop.mapreduce.JobContext context, Class<?> scope)
void	partition(T entry, Partitioner.PartitionDataCallback callback)
void	setup(PropertyManagement runTimeProperties, Class<?> scope, org.apache.hadoop.conf.Configuration configuration)

Method Detail

initialize

void initialize(org.apache.hadoop.mapreduce.JobContext context,
                Class<?> scope)
         throws IOException

Throws:

IOException

getCubeIdentifiers

List<Partitioner.PartitionData> getCubeIdentifiers(T entry)

partition

void partition(T entry,
               Partitioner.PartitionDataCallback callback)
        throws Exception

Throws:

Exception

getParameters

Collection<ParameterEnum<?>> getParameters()

setup

void setup(PropertyManagement runTimeProperties,
           Class<?> scope,
           org.apache.hadoop.conf.Configuration configuration)