org.locationtech.geowave.mapreduce

Class AbstractGeoWaveJobRunner

java.lang.Object

org.apache.hadoop.conf.Configured

org.locationtech.geowave.mapreduce.AbstractGeoWaveJobRunner

All Implemented Interfaces:

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

Direct Known Subclasses:

GeoWaveDedupeJobRunner

public abstract class AbstractGeoWaveJobRunner
extends org.apache.hadoop.conf.Configured
implements org.apache.hadoop.util.Tool

This class can run a basic job to query GeoWave. It manages datastore connection params, adapters, indices, query, min splits and max splits.

Field Summary

Fields

Modifier and Type	Field and Description
protected CommonQueryOptions	commonOptions
protected QueryConstraints	constraints
protected DataStorePluginOptions	dataStoreOptions
protected DataTypeQueryOptions<?>	dataTypeOptions
protected IndexQueryOptions	indexOptions
protected static org.slf4j.Logger	LOGGER
protected Integer	maxInputSplits
protected Integer	minInputSplits

Constructor Summary

Constructors

Constructor and Description
AbstractGeoWaveJobRunner(DataStorePluginOptions dataStoreOptions)

Method Summary

Modifier and Type	Method and Description
protected abstract void	configure(org.apache.hadoop.mapreduce.Job job)
int	run(String[] args)
int	runJob() Main method to execute the MapReduce analytic.
boolean	runOperation(String[] args)
void	setCommonQueryOptions(CommonQueryOptions commonOptions)
void	setDataTypeQueryOptions(DataTypeQueryOptions<?> dataTypeOptions)
void	setIndexQueryOptions(IndexQueryOptions indexOptions)
void	setMaxInputSplits(int maxInputSplits)
void	setMinInputSplits(int minInputSplits)
void	setQuery(Query<?> query)
void	setQueryConstraints(QueryConstraints constraints)

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

Field Detail

LOGGER

protected static final org.slf4j.Logger LOGGER

dataStoreOptions

protected DataStorePluginOptions dataStoreOptions

constraints

protected QueryConstraints constraints

commonOptions

protected CommonQueryOptions commonOptions

dataTypeOptions

protected DataTypeQueryOptions<?> dataTypeOptions

indexOptions

protected IndexQueryOptions indexOptions

minInputSplits

protected Integer minInputSplits

maxInputSplits

protected Integer maxInputSplits

Constructor Detail

AbstractGeoWaveJobRunner

public AbstractGeoWaveJobRunner(DataStorePluginOptions dataStoreOptions)

Method Detail

runJob

public int runJob()
           throws Exception

Main method to execute the MapReduce analytic.

Throws:

Exception

configure

protected abstract void configure(org.apache.hadoop.mapreduce.Job job)
                           throws Exception

Throws:

Exception

setMaxInputSplits

public void setMaxInputSplits(int maxInputSplits)

setMinInputSplits

public void setMinInputSplits(int minInputSplits)

setQuery

public void setQuery(Query<?> query)

setCommonQueryOptions

public void setCommonQueryOptions(CommonQueryOptions commonOptions)

setDataTypeQueryOptions

public void setDataTypeQueryOptions(DataTypeQueryOptions<?> dataTypeOptions)

setIndexQueryOptions

public void setIndexQueryOptions(IndexQueryOptions indexOptions)

setQueryConstraints

public void setQueryConstraints(QueryConstraints constraints)

run

public int run(String[] args)
        throws Exception

Specified by:

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

Throws:

Exception

runOperation

public boolean runOperation(String[] args)
                     throws org.apache.commons.cli.ParseException

Throws:

org.apache.commons.cli.ParseException