org.locationtech.geowave.mapreduce

Interface MapReduceDataStore

All Superinterfaces:

DataStore

All Known Implementing Classes:

AccumuloDataStore, BaseMapReduceDataStore, CassandraDataStore, DynamoDBDataStore, FileSystemDataStore, HBaseDataStore, KuduDataStore, RedisDataStore, RocksDBDataStore

public interface MapReduceDataStore
extends DataStore

Method Summary

Modifier and Type	Method and Description
org.apache.hadoop.mapreduce.RecordReader<GeoWaveInputKey,?>	createRecordReader(CommonQueryOptions commonOptions, DataTypeQueryOptions<?> typeOptions, IndexQueryOptions indexOptions, QueryConstraints constraints, TransientAdapterStore adapterStore, InternalAdapterStore internalAdapterStore, AdapterIndexMappingStore aimStore, DataStatisticsStore statsStore, IndexStore indexStore, boolean isOutputWritable, org.apache.hadoop.mapreduce.InputSplit inputSplit)
org.apache.hadoop.mapreduce.RecordWriter<GeoWaveOutputKey<Object>,Object>	createRecordWriter(org.apache.hadoop.mapreduce.TaskAttemptContext context, IndexStore jobContextIndexStore, TransientAdapterStore jobContextAdapterStore)
List<org.apache.hadoop.mapreduce.InputSplit>	getSplits(CommonQueryOptions commonOptions, DataTypeQueryOptions<?> typeOptions, IndexQueryOptions indexOptions, QueryConstraints constraints, TransientAdapterStore adapterStore, AdapterIndexMappingStore aimStore, DataStatisticsStore statsStore, InternalAdapterStore internalAdapterStore, IndexStore indexStore, org.apache.hadoop.mapreduce.JobContext context, Integer minSplits, Integer maxSplits)
void	prepareRecordWriter(org.apache.hadoop.conf.Configuration conf)

Methods inherited from interface org.locationtech.geowave.core.store.api.DataStore

addEmptyStatistic, addIndex, addIndex, addStatistic, addType, addType, addType, aggregate, aggregateStatistics, copyTo, copyTo, createWriter, createWriter, delete, deleteAll, getBinnedStatisticValues, getBinnedStatisticValues, getDataTypeStatistic, getDataTypeStatistics, getFieldStatistic, getFieldStatistics, getIndex, getIndexStatistic, getIndexStatistics, getIndices, getIndices, getStatisticValue, getStatisticValue, getType, getTypes, ingest, ingest, query, query, queryStatistics, recalcStatistic, removeIndex, removeIndex, removeStatistic, removeType

Method Detail

createRecordReader

org.apache.hadoop.mapreduce.RecordReader<GeoWaveInputKey,?> createRecordReader(CommonQueryOptions commonOptions,
                                                                               DataTypeQueryOptions<?> typeOptions,
                                                                               IndexQueryOptions indexOptions,
                                                                               QueryConstraints constraints,
                                                                               TransientAdapterStore adapterStore,
                                                                               InternalAdapterStore internalAdapterStore,
                                                                               AdapterIndexMappingStore aimStore,
                                                                               DataStatisticsStore statsStore,
                                                                               IndexStore indexStore,
                                                                               boolean isOutputWritable,
                                                                               org.apache.hadoop.mapreduce.InputSplit inputSplit)
                                                                        throws IOException,
                                                                               InterruptedException

Throws:

IOException

InterruptedException

getSplits

List<org.apache.hadoop.mapreduce.InputSplit> getSplits(CommonQueryOptions commonOptions,
                                                       DataTypeQueryOptions<?> typeOptions,
                                                       IndexQueryOptions indexOptions,
                                                       QueryConstraints constraints,
                                                       TransientAdapterStore adapterStore,
                                                       AdapterIndexMappingStore aimStore,
                                                       DataStatisticsStore statsStore,
                                                       InternalAdapterStore internalAdapterStore,
                                                       IndexStore indexStore,
                                                       org.apache.hadoop.mapreduce.JobContext context,
                                                       Integer minSplits,
                                                       Integer maxSplits)
                                                throws IOException,
                                                       InterruptedException

Throws:

IOException

InterruptedException

createRecordWriter

org.apache.hadoop.mapreduce.RecordWriter<GeoWaveOutputKey<Object>,Object> createRecordWriter(org.apache.hadoop.mapreduce.TaskAttemptContext context,
                                                                                             IndexStore jobContextIndexStore,
                                                                                             TransientAdapterStore jobContextAdapterStore)

prepareRecordWriter

void prepareRecordWriter(org.apache.hadoop.conf.Configuration conf)