oracle.spatial.hadoop.vector.mapred

Class SpatialIndexingMapper<K,V>

java.lang.Object

org.apache.hadoop.mapred.MapReduceBase

oracle.spatial.hadoop.vector.mapred.SpatialIndexingMapper<K,V>

Type Parameters:

K - The type of the keys returned by the internalInputFormat

V - the type of the values returned by the internalInputFormat

All Implemented Interfaces:

java.io.Closeable, java.lang.AutoCloseable, org.apache.hadoop.mapred.JobConfigurable, org.apache.hadoop.mapred.Mapper<org.apache.hadoop.io.NullWritable,org.apache.hadoop.mapred.FileSplit,org.apache.hadoop.io.Text,RTreeWritable>

public class SpatialIndexingMapper<K,V>
extends org.apache.hadoop.mapred.MapReduceBase
implements org.apache.hadoop.mapred.Mapper<org.apache.hadoop.io.NullWritable,org.apache.hadoop.mapred.FileSplit,org.apache.hadoop.io.Text,RTreeWritable>

This mapper generates a spatial index for each FileSplit input value.

The output key will be the string representation of the input FileSplit and the value will be an instance of RTreeWritable.

The resulting RTree will contain instances of RecordInfo which are built using the information returned by the configured RecordInfoProvider.

Optionally, MVSuggest can be used to find an approximate location for records with no geometry. If the location's geometry found for a record is other than a point, a centroid is calculated and assigned to the record as its geometry. If it is the case, the RecordInfoProvider should also implement LocalizableRecordInfoProvider in order to retrieve the search text for each record

Expected configuration

• ConfigParams.INTERNAL_INPUT_FORMAT
• ConfigParams.RECORD_INFO_PROVIDER
• MVSConfig.CONF_SERVCE_LOCATION: optional
• MVSConfig.CONF_MATCH_LAYERS: optional

Constructor Summary

Constructors

Constructor and Description
SpatialIndexingMapper()

Method Summary

Modifier and Type	Method and Description
void	close()
void	configure(org.apache.hadoop.mapred.JobConf conf)
void	map(org.apache.hadoop.io.NullWritable key, org.apache.hadoop.mapred.FileSplit value, org.apache.hadoop.mapred.OutputCollector<org.apache.hadoop.io.Text,RTreeWritable> out, org.apache.hadoop.mapred.Reporter reporter)

Methods inherited from class java.lang.Object

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

Constructor Detail

SpatialIndexingMapper

public SpatialIndexingMapper()

Method Detail

configure

public void configure(org.apache.hadoop.mapred.JobConf conf)

Specified by:

configure in interface org.apache.hadoop.mapred.JobConfigurable

Overrides:

configure in class org.apache.hadoop.mapred.MapReduceBase

map

public void map(org.apache.hadoop.io.NullWritable key,
                org.apache.hadoop.mapred.FileSplit value,
                org.apache.hadoop.mapred.OutputCollector<org.apache.hadoop.io.Text,RTreeWritable> out,
                org.apache.hadoop.mapred.Reporter reporter)
         throws java.io.IOException

Specified by:

map in interface org.apache.hadoop.mapred.Mapper<org.apache.hadoop.io.NullWritable,org.apache.hadoop.mapred.FileSplit,org.apache.hadoop.io.Text,RTreeWritable>

Throws:

java.io.IOException

close

public void close()
           throws java.io.IOException

Specified by:

close in interface java.io.Closeable

Specified by:

close in interface java.lang.AutoCloseable

Overrides:

close in class org.apache.hadoop.mapred.MapReduceBase

Throws:

java.io.IOException