org.locationtech.geowave.datastore.accumulo

Class AccumuloDataStore

java.lang.Object

org.locationtech.geowave.core.store.base.BaseDataStore

org.locationtech.geowave.mapreduce.BaseMapReduceDataStore

org.locationtech.geowave.datastore.accumulo.AccumuloDataStore

All Implemented Interfaces:

Closeable, AutoCloseable, DataStore, MapReduceDataStore

public class AccumuloDataStore
extends BaseMapReduceDataStore
implements Closeable

This is the Accumulo implementation of the data store. It requires an AccumuloOperations instance that describes how to connect (read/write data) to Apache Accumulo. It can create default implementations of the IndexStore and AdapterStore based on the operations which will persist configuration information to Accumulo tables, or an implementation of each of these stores can be passed in A DataStore can both ingest and query data based on persisted indices and data adapters. When the data is ingested it is explicitly given an index and a data adapter which is then persisted to be used in subsequent queries.

Nested Class Summary

Nested classes/interfaces inherited from class org.locationtech.geowave.core.store.base.BaseDataStore

BaseDataStore.DeletionMode

Field Summary

Fields inherited from class org.locationtech.geowave.mapreduce.BaseMapReduceDataStore

splitsProvider

Fields inherited from class org.locationtech.geowave.core.store.base.BaseDataStore

adapterStore, baseOperations, baseOptions, indexMappingStore, indexStore, internalAdapterStore, propertyStore, statisticsStore

Constructor Summary

Constructors

Constructor and Description
AccumuloDataStore(AccumuloOperations accumuloOperations, AccumuloOptions accumuloOptions)

Method Summary

Modifier and Type	Method and Description
void	close() This is not a typical resource, it references a static Accumulo connector used by all DataStore instances with common connection parameters.
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)
protected void	initOnIndexWriterCreate(InternalDataAdapter adapter, Index index)
void	prepareRecordWriter(org.apache.hadoop.conf.Configuration conf)

Methods inherited from class org.locationtech.geowave.mapreduce.BaseMapReduceDataStore

createRecordReader, createRecordWriter

Methods inherited from class org.locationtech.geowave.core.store.base.BaseDataStore

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, internalQuery, internalQuery, internalQuery, internalQueryStatistics, isReverseIterationSupported, query, query, query, queryConstraints, queryInsertionId, queryRowPrefix, queryStatistics, recalcStatistic, removeIndex, removeIndex, removeStatistic, removeType, store, store

Methods inherited from class java.lang.Object

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

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

Constructor Detail

AccumuloDataStore

public AccumuloDataStore(AccumuloOperations accumuloOperations,
                         AccumuloOptions accumuloOptions)

Method Detail

createSplitsProvider

protected SplitsProvider createSplitsProvider()

Overrides:

createSplitsProvider in class BaseMapReduceDataStore

initOnIndexWriterCreate

protected void initOnIndexWriterCreate(InternalDataAdapter adapter,
                                       Index index)

Overrides:

initOnIndexWriterCreate in class BaseDataStore

close

public void close()

This is not a typical resource, it references a static Accumulo connector used by all DataStore instances with common connection parameters. Closing this is only recommended when the JVM no longer needs any connection to this Accumulo store with common connection parameters.

Specified by:

close in interface Closeable

Specified by:

close in interface AutoCloseable

getSplits

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

Specified by:

getSplits in interface MapReduceDataStore

Overrides:

getSplits in class BaseMapReduceDataStore

Throws:

IOException

InterruptedException

prepareRecordWriter

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

Specified by:

prepareRecordWriter in interface MapReduceDataStore

Overrides:

prepareRecordWriter in class BaseMapReduceDataStore