oracle.spatial.hadoop.vector.mapred

Class SpatialIndexingMapper<K,V>

java.lang.Object

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

public class SpatialIndexingMapper<K,V>
extends MapReduceBase

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

Author:

hsaucedo

Constructor Summary

Constructors

Constructor and Description
SpatialIndexingMapper()

Method Summary

Modifier and Type	Method and Description
void	close()
void	configure(JobConf conf)
void	map(NullWritable key, InputSplit value, <any> out, Reporter reporter)

Methods inherited from class java.lang.Object

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

Constructor Detail

SpatialIndexingMapper

public SpatialIndexingMapper()

Method Detail

close

public void close()
           throws java.io.IOException

Throws:

java.io.IOException

configure

public void configure(JobConf conf)

map

public void map(NullWritable key,
                InputSplit value,
                <any> out,
                Reporter reporter)
         throws java.io.IOException

Throws:

java.io.IOException