org.locationtech.geowave.analytic.mapreduce.kde.compare

Class ComparisonStatsJobRunner

java.lang.Object

org.apache.hadoop.conf.Configured

org.locationtech.geowave.analytic.mapreduce.kde.KDEJobRunner

org.locationtech.geowave.analytic.mapreduce.kde.compare.ComparisonStatsJobRunner

All Implemented Interfaces:

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

public class ComparisonStatsJobRunner
extends KDEJobRunner

Field Summary

Fields inherited from class org.locationtech.geowave.analytic.mapreduce.kde.KDEJobRunner

configFile, COVERAGE_NAME_KEY, GEOWAVE_CLASSPATH_JARS, INPUT_CRSCODE_KEY, inputDataStoreOptions, kdeCommandLineOptions, MAX_LEVEL_KEY, MIN_LEVEL_KEY, OUTPUT_CRSCODE_KEY, outputDataStoreOptions, outputIndex, TILE_SIZE, X_MAX_KEY, X_MIN_KEY, Y_MAX_KEY, Y_MIN_KEY

Constructor Summary

Constructors

Constructor and Description
ComparisonStatsJobRunner(ComparisonCommandLineOptions inputOptions, KDECommandLineOptions kdeCommandLineOptions, DataStorePluginOptions inputDataStoreOptions, DataStorePluginOptions outputDataStoreOptions, File configFile, Index outputIndex)

Method Summary

Modifier and Type	Method and Description
protected Class	getJob1Mapper()
protected String	getJob1Name()
protected Class	getJob1Reducer()
protected String	getJob2Name()
protected int	getJob2NumReducers(int numLevels)
protected Class	getJob2OutputFormatClass()
protected Class	getJob2OutputKeyClass()
protected Class	getJob2OutputValueClass()
protected Class	getJob2Partitioner()
protected Class	getJob2Reducer()
static void	main(String[] args)
protected boolean	postJob2Actions(org.apache.hadoop.conf.Configuration conf, String statsNamespace, String coverageName)
protected void	preJob1Setup(org.apache.hadoop.conf.Configuration conf)
protected void	setupEntriesPerLevel(org.apache.hadoop.mapreduce.Job job1, org.apache.hadoop.conf.Configuration conf)
protected void	setupJob2Output(org.apache.hadoop.conf.Configuration conf, org.apache.hadoop.mapreduce.Job statsReducer, String statsNamespace, String coverageName, Index index)

Methods inherited from class org.locationtech.geowave.analytic.mapreduce.kde.KDEJobRunner

addJobClasspathDependencies, run, runJob, setup

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

ComparisonStatsJobRunner

public ComparisonStatsJobRunner(ComparisonCommandLineOptions inputOptions,
                                KDECommandLineOptions kdeCommandLineOptions,
                                DataStorePluginOptions inputDataStoreOptions,
                                DataStorePluginOptions outputDataStoreOptions,
                                File configFile,
                                Index outputIndex)

Method Detail

main

public static void main(String[] args)
                 throws Exception

Throws:

Exception

preJob1Setup

protected void preJob1Setup(org.apache.hadoop.conf.Configuration conf)

Overrides:

preJob1Setup in class KDEJobRunner

postJob2Actions

protected boolean postJob2Actions(org.apache.hadoop.conf.Configuration conf,
                                  String statsNamespace,
                                  String coverageName)
                           throws Exception

Overrides:

postJob2Actions in class KDEJobRunner

Throws:

Exception

getJob2OutputFormatClass

protected Class getJob2OutputFormatClass()

Overrides:

getJob2OutputFormatClass in class KDEJobRunner

getJob2OutputKeyClass

protected Class getJob2OutputKeyClass()

Overrides:

getJob2OutputKeyClass in class KDEJobRunner

getJob2OutputValueClass

protected Class getJob2OutputValueClass()

Overrides:

getJob2OutputValueClass in class KDEJobRunner

getJob2Reducer

protected Class getJob2Reducer()

Overrides:

getJob2Reducer in class KDEJobRunner

getJob2NumReducers

protected int getJob2NumReducers(int numLevels)

Overrides:

getJob2NumReducers in class KDEJobRunner

getJob1Mapper

protected Class getJob1Mapper()

Overrides:

getJob1Mapper in class KDEJobRunner

getJob1Reducer

protected Class getJob1Reducer()

Overrides:

getJob1Reducer in class KDEJobRunner

getJob2Partitioner

protected Class getJob2Partitioner()

Overrides:

getJob2Partitioner in class KDEJobRunner

getJob2Name

protected String getJob2Name()

Overrides:

getJob2Name in class KDEJobRunner

getJob1Name

protected String getJob1Name()

Overrides:

getJob1Name in class KDEJobRunner

setupEntriesPerLevel

protected void setupEntriesPerLevel(org.apache.hadoop.mapreduce.Job job1,
                                    org.apache.hadoop.conf.Configuration conf)
                             throws IOException

Overrides:

setupEntriesPerLevel in class KDEJobRunner

Throws:

IOException

setupJob2Output

protected void setupJob2Output(org.apache.hadoop.conf.Configuration conf,
                               org.apache.hadoop.mapreduce.Job statsReducer,
                               String statsNamespace,
                               String coverageName,
                               Index index)
                        throws Exception

Overrides:

setupJob2Output in class KDEJobRunner

Throws:

Exception