org.locationtech.geowave.mapreduce

Class JobContextIndexStore

java.lang.Object

org.locationtech.geowave.mapreduce.JobContextIndexStore

All Implemented Interfaces:

IndexStore

public class JobContextIndexStore
extends Object
implements IndexStore

This class implements an index store by first checking the job context for an index and keeping a local cache of indices that have been discovered. It will check the metadata store if it cannot find an index in the job context.

Constructor Summary

Constructors

Constructor and Description
JobContextIndexStore(org.apache.hadoop.mapreduce.JobContext context, IndexStore persistentIndexStore)

Method Summary

Modifier and Type	Method and Description
static void	addIndex(org.apache.hadoop.conf.Configuration config, Index index)
void	addIndex(Index index)
protected static Index	getIndex(org.apache.hadoop.mapreduce.JobContext context, String indexName)
Index	getIndex(String indexName)
CloseableIterator<Index>	getIndices()
static Index[]	getIndices(org.apache.hadoop.mapreduce.JobContext context)
boolean	indexExists(String indexName)
void	removeAll()
void	removeIndex(String indexName)

Methods inherited from class java.lang.Object

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

Constructor Detail

JobContextIndexStore

public JobContextIndexStore(org.apache.hadoop.mapreduce.JobContext context,
                            IndexStore persistentIndexStore)

Method Detail

addIndex

public void addIndex(Index index)

Specified by:

addIndex in interface IndexStore

getIndex

public Index getIndex(String indexName)

Specified by:

getIndex in interface IndexStore

indexExists

public boolean indexExists(String indexName)

Specified by:

indexExists in interface IndexStore

removeAll

public void removeAll()

Specified by:

removeAll in interface IndexStore

removeIndex

public void removeIndex(String indexName)

Specified by:

removeIndex in interface IndexStore

getIndices

public CloseableIterator<Index> getIndices()

Specified by:

getIndices in interface IndexStore

addIndex

public static void addIndex(org.apache.hadoop.conf.Configuration config,
                            Index index)

getIndex

protected static Index getIndex(org.apache.hadoop.mapreduce.JobContext context,
                                String indexName)

getIndices

public static Index[] getIndices(org.apache.hadoop.mapreduce.JobContext context)