org.locationtech.geowave.mapreduce

Class JobContextAdapterStore

java.lang.Object

org.locationtech.geowave.mapreduce.JobContextAdapterStore

All Implemented Interfaces:

AdapterStore<String,DataTypeAdapter<?>>, TransientAdapterStore

public class JobContextAdapterStore
extends Object
implements TransientAdapterStore

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

Constructor Summary

Constructors

Constructor and Description
JobContextAdapterStore(org.apache.hadoop.mapreduce.JobContext context, PersistentAdapterStore persistentAdapterStore, InternalAdapterStore internalAdapterStore)

Method Summary

Modifier and Type	Method and Description
boolean	adapterExists(String typeName) Check for the existence of the adapter with the given unique ID
void	addAdapter(DataTypeAdapter<?> adapter) Add the adapter to the store
static void	addDataAdapter(org.apache.hadoop.conf.Configuration configuration, DataTypeAdapter<?> adapter)
DataTypeAdapter<?>	getAdapter(String typeName) Get an adapter from the store by its unique ID
DataTypeAdapter<?>[]	getAdapters() Get the full set of adapters within this store
protected static DataTypeAdapter<?>	getDataAdapter(org.apache.hadoop.mapreduce.JobContext context, String typeName)
static DataTypeAdapter<?>[]	getDataAdapters(org.apache.hadoop.mapreduce.JobContext context)
List<String>	getTypeNames()
static void	removeAdapter(org.apache.hadoop.conf.Configuration configuration, String typeName)
void	removeAdapter(String typeName)
void	removeAll()

Methods inherited from class java.lang.Object

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

Constructor Detail

JobContextAdapterStore

public JobContextAdapterStore(org.apache.hadoop.mapreduce.JobContext context,
                              PersistentAdapterStore persistentAdapterStore,
                              InternalAdapterStore internalAdapterStore)

Method Detail

addAdapter

public void addAdapter(DataTypeAdapter<?> adapter)

Description copied from interface: AdapterStore

Add the adapter to the store

Specified by:

addAdapter in interface AdapterStore<String,DataTypeAdapter<?>>

Parameters:

adapter - the adapter

removeAdapter

public void removeAdapter(String typeName)

Specified by:

removeAdapter in interface AdapterStore<String,DataTypeAdapter<?>>

Parameters:

typeName - the adapter ID to remove

getAdapter

public DataTypeAdapter<?> getAdapter(String typeName)

Description copied from interface: AdapterStore

Get an adapter from the store by its unique ID

Specified by:

getAdapter in interface AdapterStore<String,DataTypeAdapter<?>>

Parameters:

typeName - the unique adapter ID

Returns:

the adapter, null if it doesn't exist

adapterExists

public boolean adapterExists(String typeName)

Description copied from interface: AdapterStore

Check for the existence of the adapter with the given unique ID

Specified by:

adapterExists in interface AdapterStore<String,DataTypeAdapter<?>>

Parameters:

typeName - the unique ID to look up

Returns:

a boolean flag indicating whether the adapter exists

removeAll

public void removeAll()

Specified by:

removeAll in interface AdapterStore<String,DataTypeAdapter<?>>

getAdapters

public DataTypeAdapter<?>[] getAdapters()

Description copied from interface: AdapterStore

Get the full set of adapters within this store

Specified by:

getAdapters in interface AdapterStore<String,DataTypeAdapter<?>>

Returns:

an iterator over all of the adapters in this store

getTypeNames

public List<String> getTypeNames()

getDataAdapter

protected static DataTypeAdapter<?> getDataAdapter(org.apache.hadoop.mapreduce.JobContext context,
                                                   String typeName)

getDataAdapters

public static DataTypeAdapter<?>[] getDataAdapters(org.apache.hadoop.mapreduce.JobContext context)

addDataAdapter

public static void addDataAdapter(org.apache.hadoop.conf.Configuration configuration,
                                  DataTypeAdapter<?> adapter)

removeAdapter

public static void removeAdapter(org.apache.hadoop.conf.Configuration configuration,
                                 String typeName)