public class BaseMapReduceDataStore extends BaseDataStore implements MapReduceDataStore
BaseDataStore.DeletionMode
Modifier and Type | Field and Description |
---|---|
protected SplitsProvider |
splitsProvider |
adapterStore, baseOperations, baseOptions, indexMappingStore, indexStore, internalAdapterStore, propertyStore, statisticsStore
Constructor and Description |
---|
BaseMapReduceDataStore(IndexStore indexStore,
PersistentAdapterStore adapterStore,
DataStatisticsStore statisticsStore,
AdapterIndexMappingStore indexMappingStore,
MapReduceDataStoreOperations operations,
DataStoreOptions options,
InternalAdapterStore adapterMappingStore,
PropertyStore propertyStore) |
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) |
protected SplitsProvider |
createSplitsProvider() |
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) |
addEmptyStatistic, addIndex, addIndex, addStatistic, addType, addType, addType, addTypeInternal, aggregate, aggregateStatistics, copyTo, copyTo, createDataIndexWriter, createIndexWriter, createWriter, createWriter, delete, delete, delete, delete, deleteAll, deleteEverything, deleteFromDataIndex, getAdapterId, getAdapterStore, getBaseOperations, getBinnedStatisticValues, getDataTypeStatistic, getDataTypeStatistics, getFieldStatistic, getFieldStatistics, getIndex, getIndexMappingStore, getIndexStatistic, getIndexStatistics, getIndexStore, getIndices, getIndices, getInternalAdapterStore, getStatisticsStore, getStatisticValue, getType, getTypes, ingest, ingest, initOnIndexWriterCreate, internalQuery, internalQuery, internalQuery, internalQueryStatistics, isReverseIterationSupported, query, query, query, queryConstraints, queryInsertionId, queryRowPrefix, queryStatistics, recalcStatistic, removeIndex, removeIndex, removeStatistic, removeType, store, store
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
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
protected final SplitsProvider splitsProvider
public BaseMapReduceDataStore(IndexStore indexStore, PersistentAdapterStore adapterStore, DataStatisticsStore statisticsStore, AdapterIndexMappingStore indexMappingStore, MapReduceDataStoreOperations operations, DataStoreOptions options, InternalAdapterStore adapterMappingStore, PropertyStore propertyStore)
public org.apache.hadoop.mapreduce.RecordWriter<GeoWaveOutputKey<Object>,Object> createRecordWriter(org.apache.hadoop.mapreduce.TaskAttemptContext context, IndexStore jobContextIndexStore, TransientAdapterStore jobContextAdapterStore)
createRecordWriter
in interface MapReduceDataStore
public void prepareRecordWriter(org.apache.hadoop.conf.Configuration conf)
prepareRecordWriter
in interface MapReduceDataStore
public 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
createRecordReader
in interface MapReduceDataStore
IOException
InterruptedException
protected SplitsProvider createSplitsProvider()
public 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
getSplits
in interface MapReduceDataStore
IOException
InterruptedException
Copyright © 2013–2022. All rights reserved.