oracle.spatial.hadoop.vector.partition

Class HilbertValueBasedPartitioner

java.lang.Object

oracle.spatial.hadoop.vector.partition.HilbertValueBasedPartitioner

public class HilbertValueBasedPartitioner
extends java.lang.Object

Constructor Summary

Constructors

Constructor and Description
HilbertValueBasedPartitioner(Path hvPointsPath, Path[] sourceDataPaths, long pointCount, double pointDistanceSum, long partitionCount) Creates a new instance
HilbertValueBasedPartitioner(Path hvPointsPath, java.lang.String[] sourceLocations, long pointCount, double pointDistanceSum, long partitionCount) Creates a new instance

Method Summary

Modifier and Type	Method and Description
void	generatePartitioningResult(Path partResultPath, SpatialConfig spatialConfig, Configuration conf) Creates partitions and generates a partitioning result file.

Methods inherited from class java.lang.Object

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

Constructor Detail

HilbertValueBasedPartitioner

public HilbertValueBasedPartitioner(Path hvPointsPath,
                                    Path[] sourceDataPaths,
                                    long pointCount,
                                    double pointDistanceSum,
                                    long partitionCount)

Creates a new instance

Parameters:

hvPointsPath - the path to a sequence file containing hilbert value-point pairs

sourceDataPaths - the paths to the data which the partitioning file will be generated for

pointCount - the number of points (entries) in the file located at hvPoinsPath

pointDistanceSum - the sum of the distance of each consecutive points in the file located at hvPoinsPath

partitionCount - the suggested number of partitions

HilbertValueBasedPartitioner

public HilbertValueBasedPartitioner(Path hvPointsPath,
                                    java.lang.String[] sourceLocations,
                                    long pointCount,
                                    double pointDistanceSum,
                                    long partitionCount)

Creates a new instance

Parameters:

hvPointsPath - the path to a sequence file containing hilbert value-point pairs

sourceLocations - the locations of the data which the partitioning file will be generated for

pointCount - the number of points (entries) in the file located at hvPoinsPath

pointDistanceSum - the sum of the distance of each consecutive points in the file located at hvPoinsPath

partitionCount - the suggested number of partitions

Method Detail

generatePartitioningResult

public void generatePartitioningResult(Path partResultPath,
                                       SpatialConfig spatialConfig,
                                       Configuration conf)
                                throws java.io.IOException

Creates partitions and generates a partitioning result file.

Parameters:

partResultPath - the path where the partitioning result file will be saved

spatialConfig - the spatial configuration that defines the paritioning space and the geometries of the generated partitions

conf - a job configuration

Throws:

java.io.IOException