oracle.spatial.hadoop.vector.cluster.kmeans.mapred

Class KMeansSampler<K,V>

java.lang.Object

oracle.spatial.hadoop.vector.cluster.kmeans.mapred.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.

Author:

hsaucedo

Constructor Summary

Constructors

Constructor and Description
KMeansSampler(<any> sampler) Creates a new instance
KMeansSampler(double freq, int numSamples, int maxSplitsSampled) Creates a new instance

Method Summary

Modifier and Type	Method and Description
PointWritable[]	getSample(AbstractInputDataSet dataSet, InputDataSetConfiguratorHandler confHandler, Configuration conf) Gets a sample of points from the input data set.
PointWritable[]	getSample(java.lang.Class<? extends <any>> inputFormatClass, java.lang.Class<? extends RecordInfoProvider<K,V>> riProviderClass, java.lang.String input, Configuration conf) Gets a sample of points from the input data set.

Methods inherited from class java.lang.Object

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

Constructor Detail

KMeansSampler

public KMeansSampler(<any> sampler)

Creates a new instance

Parameters:

sampler - a sampler implementation

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

Method Detail

getSample

public PointWritable[] getSample(AbstractInputDataSet dataSet,
                                 InputDataSetConfiguratorHandler confHandler,
                                 Configuration conf)
                          throws java.io.IOException

Gets a sample of points from the input data set.

Parameters:

dataSet - an input data set encapsulated as an AbstractInputDataSet

confHandler - a configuration handlers used to configure the given input data set

conf - a configuration instance

Returns:

an array containing PointWritable instances representing points of the sample

Throws:

java.io.IOException

getSample

public PointWritable[] getSample(java.lang.Class<? extends <any>> inputFormatClass,
                                 java.lang.Class<? extends RecordInfoProvider<K,V>> riProviderClass,
                                 java.lang.String input,
                                 Configuration conf)
                          throws java.io.IOException

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