org.locationtech.geowave.mapreduce.output

Class GeoWaveOutputFormat

java.lang.Object

org.apache.hadoop.mapreduce.OutputFormat<GeoWaveOutputKey<Object>,Object>

org.locationtech.geowave.mapreduce.output.GeoWaveOutputFormat

public class GeoWaveOutputFormat
extends org.apache.hadoop.mapreduce.OutputFormat<GeoWaveOutputKey<Object>,Object>

This output format is the preferred mechanism for writing data to GeoWave within a map-reduce job.

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static class	GeoWaveOutputFormat.GeoWaveRecordWriter A base class to be used to create RecordWriter instances that write to GeoWave.

Field Summary

Fields

Modifier and Type	Field and Description
protected static org.slf4j.Logger	LOGGER

Constructor Summary

Constructors

Constructor and Description
GeoWaveOutputFormat()

Method Summary

Modifier and Type	Method and Description
static void	addDataAdapter(org.apache.hadoop.conf.Configuration config, DataTypeAdapter<?> adapter)
static void	addIndex(org.apache.hadoop.conf.Configuration config, Index index)
void	checkOutputSpecs(org.apache.hadoop.mapreduce.JobContext context)
static AdapterIndexMappingStore	getJobContextAdapterIndexMappingStore(org.apache.hadoop.mapreduce.JobContext context)
static AdapterStore	getJobContextAdapterStore(org.apache.hadoop.mapreduce.JobContext context)
static IndexStore	getJobContextIndexStore(org.apache.hadoop.mapreduce.JobContext context)
static InternalAdapterStore	getJobContextInternalAdapterStore(org.apache.hadoop.mapreduce.JobContext context)
org.apache.hadoop.mapreduce.OutputCommitter	getOutputCommitter(org.apache.hadoop.mapreduce.TaskAttemptContext context)
org.apache.hadoop.mapreduce.RecordWriter<GeoWaveOutputKey<Object>,Object>	getRecordWriter(org.apache.hadoop.mapreduce.TaskAttemptContext context)
static DataStorePluginOptions	getStoreOptions(org.apache.hadoop.mapreduce.JobContext context)
static Map<String,String>	getStoreOptionsMap(org.apache.hadoop.mapreduce.JobContext context)
static void	setStoreOptions(org.apache.hadoop.conf.Configuration config, DataStorePluginOptions storeOptions)

Methods inherited from class java.lang.Object

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

Field Detail

LOGGER

protected static final org.slf4j.Logger LOGGER

Constructor Detail

GeoWaveOutputFormat

public GeoWaveOutputFormat()

Method Detail

getRecordWriter

public org.apache.hadoop.mapreduce.RecordWriter<GeoWaveOutputKey<Object>,Object> getRecordWriter(org.apache.hadoop.mapreduce.TaskAttemptContext context)
                                                                                          throws IOException,
                                                                                                 InterruptedException

Specified by:

getRecordWriter in class org.apache.hadoop.mapreduce.OutputFormat<GeoWaveOutputKey<Object>,Object>

Throws:

IOException

InterruptedException

setStoreOptions

public static void setStoreOptions(org.apache.hadoop.conf.Configuration config,
                                   DataStorePluginOptions storeOptions)

addIndex

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

addDataAdapter

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

getJobContextIndexStore

public static IndexStore getJobContextIndexStore(org.apache.hadoop.mapreduce.JobContext context)

getJobContextAdapterStore

public static AdapterStore getJobContextAdapterStore(org.apache.hadoop.mapreduce.JobContext context)

getJobContextAdapterIndexMappingStore

public static AdapterIndexMappingStore getJobContextAdapterIndexMappingStore(org.apache.hadoop.mapreduce.JobContext context)

getJobContextInternalAdapterStore

public static InternalAdapterStore getJobContextInternalAdapterStore(org.apache.hadoop.mapreduce.JobContext context)

getStoreOptions

public static DataStorePluginOptions getStoreOptions(org.apache.hadoop.mapreduce.JobContext context)

getStoreOptionsMap

public static Map<String,String> getStoreOptionsMap(org.apache.hadoop.mapreduce.JobContext context)

checkOutputSpecs

public void checkOutputSpecs(org.apache.hadoop.mapreduce.JobContext context)
                      throws IOException,
                             InterruptedException

Specified by:

checkOutputSpecs in class org.apache.hadoop.mapreduce.OutputFormat<GeoWaveOutputKey<Object>,Object>

Throws:

IOException

InterruptedException

getOutputCommitter

public org.apache.hadoop.mapreduce.OutputCommitter getOutputCommitter(org.apache.hadoop.mapreduce.TaskAttemptContext context)
                                                               throws IOException,
                                                                      InterruptedException

Specified by:

getOutputCommitter in class org.apache.hadoop.mapreduce.OutputFormat<GeoWaveOutputKey<Object>,Object>

Throws:

IOException

InterruptedException