oracle.spatial.hadoop.vector.cluster.kmeans.mapreduce

Class KMeansSampler<K,V>

java.lang.Object

oracle.spatial.hadoop.vector.cluster.kmeans.mapreduce.KMeansSampler<K,V>

Type Parameters:

K - The type of the input keys

V - The type of the input values

public class KMeansSampler<K,V>
extends java.lang.Object

Provides a sample containing points from an input data set. The geometries of the input data set records may be other type than points.

Constructor Summary

Constructors

Constructor and Description
KMeansSampler(double freq, int numSamples, int maxSplitsSampled) Creates a new instance
KMeansSampler(org.apache.hadoop.mapreduce.lib.partition.InputSampler.Sampler<PointWritable,org.apache.hadoop.io.NullWritable> sampler) Creates a new instance

Method Summary

Modifier and Type	Method and Description
PointWritable[]	getSample(java.lang.Class<? extends org.apache.hadoop.mapreduce.lib.input.FileInputFormat<K,V>> inputFormatClass, java.lang.Class<? extends RecordInfoProvider<K,V>> riProviderClass, java.lang.String input, org.apache.hadoop.conf.Configuration conf) Gets a sample of points from the input data set.

Methods inherited from class java.lang.Object

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

Constructor Detail

KMeansSampler

public KMeansSampler(double freq,
                     int numSamples,
                     int maxSplitsSampled)

Creates a new instance

Parameters:

freq - the portion to sample

numSamples - maximum number of samples to take

maxSplitsSampled - maximum number of splits to sample

KMeansSampler

public KMeansSampler(org.apache.hadoop.mapreduce.lib.partition.InputSampler.Sampler<PointWritable,org.apache.hadoop.io.NullWritable> sampler)

Creates a new instance

Parameters:

sampler - a sampler implementation

Method Detail

getSample

public PointWritable[] getSample(java.lang.Class<? extends org.apache.hadoop.mapreduce.lib.input.FileInputFormat<K,V>> inputFormatClass,
                                 java.lang.Class<? extends RecordInfoProvider<K,V>> riProviderClass,
                                 java.lang.String input,
                                 org.apache.hadoop.conf.Configuration conf)
                          throws java.io.IOException,
                                 java.lang.InterruptedException

Gets a sample of points from the input data set.

Parameters:

inputFormatClass - class used to read the input data set

riProviderClass - class used to extract spatial information from input records

input - defines the path of the input data set

conf - a job configuration

Returns:

an array of sampled points

Throws:

java.io.IOException

java.lang.InterruptedException