org.locationtech.geowave.datastore.cassandra

Class CassandraDataStore

java.lang.Object

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

org.locationtech.geowave.mapreduce.BaseMapReduceDataStore

org.locationtech.geowave.datastore.cassandra.CassandraDataStore

All Implemented Interfaces:

DataStore, MapReduceDataStore

public class CassandraDataStore
extends BaseMapReduceDataStore

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
CassandraDataStore(CassandraOperations operations, CassandraOptions options)

Method Summary

Modifier and Type	Method and Description
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 class org.locationtech.geowave.mapreduce.BaseMapReduceDataStore

createRecordReader, createRecordWriter, createSplitsProvider

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, initOnIndexWriterCreate, 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

CassandraDataStore

public CassandraDataStore(CassandraOperations operations,
                          CassandraOptions options)

Method Detail

prepareRecordWriter

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

Specified by:

prepareRecordWriter in interface MapReduceDataStore

Overrides:

prepareRecordWriter in class BaseMapReduceDataStore

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