oracle.spatial.hadoop.vector.mapreduce.job

Class Categorization<K,V>

java.lang.Object

org.apache.hadoop.conf.Configured

oracle.spatial.hadoop.vector.mapred.job.BaseJob<K,V>

oracle.spatial.hadoop.vector.mapred.job.IndexedInputBaseJob<K,V>

oracle.spatial.hadoop.vector.mapred.job.Categorization<K,V>

oracle.spatial.hadoop.vector.mapreduce.job.Categorization<K,V>

Type Parameters:

K - the type of the input keys

V - the type of the input values

All Implemented Interfaces:

org.apache.hadoop.conf.Configurable, org.apache.hadoop.util.Tool

public class Categorization<K,V>
extends Categorization<K,V>

This class can be used to run or configure a job for categorizing records of an input dataset into features of a hierarchical dataset.

The result will be a summary file for each hierarchical level containing the number of records from the non-hierarchical dataset per hierarchy level feature.

The categorization can be performed determining a spatial interaction specified by a spatial operation or using MVSuggest.

Field Summary

Fields inherited from class oracle.spatial.hadoop.vector.mapred.job.Categorization

mvsService

Fields inherited from class oracle.spatial.hadoop.vector.mapred.job.BaseJob

argsp, inputDataSet, jarClass, jobRegEntryPath, proxyIDS

Constructor Summary

Constructors

Constructor and Description
Categorization()

Method Summary

Methods

Modifier and Type	Method and Description
void	configure(org.apache.hadoop.mapreduce.Job job) Validates and adds the current parameters to the job configuration
protected InputDataSetConfiguratorHandler	getInputDataSetConfiguratorHandler(org.apache.hadoop.conf.Configuration conf) Returns the current instance of InputDataSetConfiguratorHandler used to configure the input data set
static <K,V> void	main(java.lang.String[] args)
int	run(java.lang.String[] args)

Methods inherited from class oracle.spatial.hadoop.vector.mapred.job.Categorization

configure, getCmdOptions, getCurrentCmdArgs, getHierarchyDataPaths, getHierarchyIndexPath, getHierarchyInfoClass, getInputDataSetCmdParserHandler, getMvsConfig, getSpatialOperationConfig, processArgs, setHierarchyDataPaths, setHierarchyIndexPath, setHierarchyInfoClass, setMvsConfig, setSpatialOperationConfig

Methods inherited from class oracle.spatial.hadoop.vector.mapred.job.IndexedInputBaseJob

getIndexMetadataDir, getIndexName, getProxyIDS, isInputIndex, setIndexMetadataDir, setIndexName, setInputIndex, updateInputDataSet

Methods inherited from class oracle.spatial.hadoop.vector.mapred.job.BaseJob

addJobRegistryEntry, addJobRegistryEntry, addJobRegistryEntry, createJob, createJob, createJob, createJob, createJobConf, createJobConf, createJobConf, getCmdOptionsWithInputDataSets, getCmdOptionsWithInputDataSets, getCurrentCmdArgsAsString, getCurrentCmdArgsAsString, getInput, getInputDataSet, getInputFormatClass, getJarClass, getOutput, getRecordInfoProviderClass, getSpatialConfig, runJob, runJob, setInput, setInputDataSet, setInputFormatClass, setJarClass, setOutput, setRecordInfoProviderClass, setSpatialConfig

Methods inherited from class org.apache.hadoop.conf.Configured

getConf, setConf

Methods inherited from class java.lang.Object

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

Methods inherited from interface org.apache.hadoop.conf.Configurable

getConf, setConf

Constructor Detail

Categorization

public Categorization()

Method Detail

getInputDataSetConfiguratorHandler

protected InputDataSetConfiguratorHandler getInputDataSetConfiguratorHandler(org.apache.hadoop.conf.Configuration conf)

Description copied from class: BaseJob

Returns the current instance of InputDataSetConfiguratorHandler used to configure the input data set

Overrides:

getInputDataSetConfiguratorHandler in class Categorization<K,V>

Parameters:

conf - a job configuration

Returns:

an instance of InputDataSetConfiguratorHandler

configure

public void configure(org.apache.hadoop.mapreduce.Job job)
               throws java.lang.Exception

Description copied from class: BaseJob

Validates and adds the current parameters to the job configuration

Overrides:

configure in class BaseJob<K,V>

Parameters:

job - a job instance

Throws:

java.lang.Exception

run

public int run(java.lang.String[] args)
        throws java.lang.Exception

Specified by:

run in interface org.apache.hadoop.util.Tool

Overrides:

run in class Categorization<K,V>

Throws:

java.lang.Exception

main

public static <K,V> void main(java.lang.String[] args)
                       throws java.lang.Exception

Throws:

java.lang.Exception