org.locationtech.geowave.analytic.mapreduce.nn

Class NNMapReduce.PassthruPartitioner<T>

java.lang.Object

org.locationtech.geowave.analytic.mapreduce.nn.NNMapReduce.PassthruPartitioner<T>

All Implemented Interfaces:

Serializable, Partitioner<T>

Enclosing class:

NNMapReduce

public static class NNMapReduce.PassthruPartitioner<T>
extends Object
implements Partitioner<T>

See Also:

Serialized Form

Nested Class Summary

Nested classes/interfaces inherited from interface org.locationtech.geowave.analytic.partitioner.Partitioner

Partitioner.PartitionData, Partitioner.PartitionDataCallback

Constructor Summary

Constructors

Constructor and Description
PassthruPartitioner()

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)

Methods inherited from class java.lang.Object

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

Constructor Detail

PassthruPartitioner

public PassthruPartitioner()

Method Detail

initialize

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

Specified by:

initialize in interface Partitioner<T>

Throws:

IOException

getCubeIdentifiers

public List<Partitioner.PartitionData> getCubeIdentifiers(T entry)

Specified by:

getCubeIdentifiers in interface Partitioner<T>

partition

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

Specified by:

partition in interface Partitioner<T>

Throws:

Exception

getParameters

public Collection<ParameterEnum<?>> getParameters()

Specified by:

getParameters in interface Partitioner<T>

setup

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

Specified by:

setup in interface Partitioner<T>