org.locationtech.geowave.mapreduce.output

Class GeoWaveOutputFormat.GeoWaveRecordWriter

java.lang.Object

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

org.locationtech.geowave.mapreduce.output.GeoWaveOutputFormat.GeoWaveRecordWriter

Enclosing class:

GeoWaveOutputFormat

public static class GeoWaveOutputFormat.GeoWaveRecordWriter
extends org.apache.hadoop.mapreduce.RecordWriter<GeoWaveOutputKey<Object>,Object>

A base class to be used to create RecordWriter instances that write to GeoWave.

Constructor Summary

Constructors

Constructor and Description
GeoWaveRecordWriter(DataStore dataStore, IndexStore indexStore, TransientAdapterStore adapterStore)

Method Summary

Modifier and Type	Method and Description
void	close(org.apache.hadoop.mapreduce.TaskAttemptContext attempt)
void	write(GeoWaveOutputKey ingestKey, Object data) Push a mutation into a table.

Methods inherited from class java.lang.Object

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

Constructor Detail

GeoWaveRecordWriter

public GeoWaveRecordWriter(DataStore dataStore,
                           IndexStore indexStore,
                           TransientAdapterStore adapterStore)

Method Detail

write

public void write(GeoWaveOutputKey ingestKey,
                  Object data)
           throws IOException

Push a mutation into a table. If table is null, the defaultTable will be used. If canCreateTable is set, the table will be created if it does not exist. The table name must only contain alphanumerics and underscore.

Specified by:

write in class org.apache.hadoop.mapreduce.RecordWriter<GeoWaveOutputKey<Object>,Object>

Throws:

IOException

close

public void close(org.apache.hadoop.mapreduce.TaskAttemptContext attempt)
           throws IOException,
                  InterruptedException

Specified by:

close in class org.apache.hadoop.mapreduce.RecordWriter<GeoWaveOutputKey<Object>,Object>

Throws:

IOException

InterruptedException