oracle.spatial.hadoop.rasterapi.core.jobs

Class RasterJob

java.lang.Object

oracle.spatial.hadoop.rasterapi.core.jobs.RasterJob

Direct Known Subclasses:

RasterLoaderJob, RasterProcessorJob

public class RasterJob
extends java.lang.Object

Represents a base Hadooop job that can be executed using the received configuration. Can be used to create and execute any job that user may have

Field Summary

Fields

Modifier and Type	Field and Description
protected boolean	gdalPathSet
protected org.apache.hadoop.mapreduce.Job	job
protected java.util.logging.Logger	log

Constructor Summary

Constructors

Constructor and Description
RasterJob(org.apache.hadoop.conf.Configuration config) Job constructor using a previously existing configuration

Method Summary

Modifier and Type	Method and Description
boolean	execute(java.lang.String jobName, java.lang.Class<? extends org.apache.hadoop.mapreduce.InputFormat> inputFormat, java.lang.Class executingClass, java.lang.Class<? extends org.apache.hadoop.mapreduce.Mapper> mapperClass, java.lang.Class<? extends org.apache.hadoop.mapreduce.Reducer> reducerClass, java.lang.Class mapOutputValue, java.lang.Class mapOutputKey, java.lang.Class outputValue, java.lang.Class outputKey, java.lang.String outputPath) Executes this job, using the received configuration params
org.apache.hadoop.mapreduce.Job	getHadoopJob() Job´s getter

Methods inherited from class java.lang.Object

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

Field Detail

job

protected org.apache.hadoop.mapreduce.Job job

gdalPathSet

protected boolean gdalPathSet

log

protected java.util.logging.Logger log

Constructor Detail

RasterJob

public RasterJob(org.apache.hadoop.conf.Configuration config)

Job constructor using a previously existing configuration

Parameters:

config - job configuration with previously loaded properties.

Method Detail

getHadoopJob

public org.apache.hadoop.mapreduce.Job getHadoopJob()

Job´s getter

Returns:

this job´s instance

execute

public final boolean execute(java.lang.String jobName,
                             java.lang.Class<? extends org.apache.hadoop.mapreduce.InputFormat> inputFormat,
                             java.lang.Class executingClass,
                             java.lang.Class<? extends org.apache.hadoop.mapreduce.Mapper> mapperClass,
                             java.lang.Class<? extends org.apache.hadoop.mapreduce.Reducer> reducerClass,
                             java.lang.Class mapOutputValue,
                             java.lang.Class mapOutputKey,
                             java.lang.Class outputValue,
                             java.lang.Class outputKey,
                             java.lang.String outputPath)
                      throws java.lang.Exception

Executes this job, using the received configuration params

Parameters:

jobName - name of this job

inputFormat - InputFormat class for this job

executingClass - name of the class containing the map and reduce classes for this job

mapperClass - name of the mapper class

reducerClass - name of the reducer class

mapOutputValue - mapper´s output value class

mapOutputKey - mapper´s output key class

outputValue - reducer´s output value class

outputKey - reducer´s output key class

outputPath - hdfs output path for this job results

Returns:

true if job executed successfully, or galse otherwise

Throws:

java.lang.Exception - whenever there is a problem during the execution of this job.