oracle.spatial.hadoop.vector.mapreduce.input

Class SpatialSampler<K,V>

java.lang.Object

oracle.spatial.hadoop.vector.mapreduce.input.SpatialSampler<K,V>

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

Constructor Summary

Constructors

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

Method Summary

Modifier and Type	Method and Description
JGeometryWritable[]	getSample(AbstractInputDataSet dataSet, InputDataSetConfiguratorHandler confHandler, Configuration conf)
void	writeSample(AbstractInputDataSet dataSet, InputDataSetConfiguratorHandler confHandler, Path resultPath, Configuration conf)

Methods inherited from class java.lang.Object

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

Constructor Detail

SpatialSampler

public SpatialSampler(<any> sampler)

Creates a new instance

Parameters:

sampler - a sampler implementation

SpatialSampler

public SpatialSampler(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 JGeometryWritable[] getSample(AbstractInputDataSet dataSet,
                                     InputDataSetConfiguratorHandler confHandler,
                                     Configuration conf)
                              throws java.io.IOException,
                                     java.lang.InterruptedException

Throws:

java.io.IOException

java.lang.InterruptedException

writeSample

public void writeSample(AbstractInputDataSet dataSet,
                        InputDataSetConfiguratorHandler confHandler,
                        Path resultPath,
                        Configuration conf)
                 throws java.io.IOException,
                        java.lang.InterruptedException

Throws:

java.io.IOException

java.lang.InterruptedException