org.locationtech.geowave.datastore.dynamodb.operations

Class DynamoDBOperations

java.lang.Object

org.locationtech.geowave.datastore.dynamodb.operations.DynamoDBOperations

All Implemented Interfaces:

DataStoreOperations, MapReduceDataStoreOperations

public class DynamoDBOperations
extends Object
implements MapReduceDataStoreOperations

Field Summary

Fields

Modifier and Type	Field and Description
static int	MAX_ROWS_FOR_BATCHGETITEM
static int	MAX_ROWS_FOR_BATCHWRITER
static String	METADATA_PRIMARY_ID_KEY
static String	METADATA_SECONDARY_ID_KEY
static String	METADATA_TIMESTAMP_KEY
static String	METADATA_VALUE_KEY
static String	METADATA_VISIBILITY_KEY
static Map<String,Boolean>	tableExistsCache

Constructor Summary

Constructors

Constructor and Description
DynamoDBOperations(DynamoDBOptions options)

Method Summary

Modifier and Type	Method and Description
RowWriter	createDataIndexWriter(InternalDataAdapter<?> adapter)
boolean	createIndex(Index index)
MetadataDeleter	createMetadataDeleter(MetadataType metadataType)
MetadataReader	createMetadataReader(MetadataType metadataType)
MetadataWriter	createMetadataWriter(MetadataType metadataType)
static DynamoDBOperations	createOperations(DynamoDBOptions options)
RowReader<GeoWaveRow>	createReader(DataIndexReaderParams readerParams)
<T> RowReader<T>	createReader(ReaderParams<T> readerParams)
RowReader<GeoWaveRow>	createReader(RecordReaderParams recordReaderParams)
RowDeleter	createRowDeleter(String indexName, PersistentAdapterStore adapterStore, InternalAdapterStore internalAdapterStore, String... authorizations)
RowWriter	createWriter(Index index, InternalDataAdapter<?> adapter)
void	delete(DataIndexReaderParams readerParams)
void	deleteAll()
boolean	deleteAll(String indexName, String typeName, Short adapterId, String... additionalAuthorizations)
void	deleteRowsFromDataIndex(byte[][] dataIds, short adapterId, String typeName)
boolean	ensureAuthorizations(String clientUser, String... authorizations)
com.amazonaws.services.dynamodbv2.AmazonDynamoDBAsync	getClient()
String	getMetadataTableName(MetadataType metadataType)
DynamoDBOptions	getOptions()
String	getQualifiedTableName(String tableName)
Iterator<GeoWaveRow>	getRowsFromDataIndex(byte[][] dataIds, short adapterId, String typeName)
Iterator<GeoWaveRow>	getRowsFromDataIndex(short adapterId, String typeName)
boolean	indexExists(String indexName)
boolean	metadataExists(MetadataType type)

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.operations.DataStoreOperations

createDeleter, mergeData, mergeStats

Field Detail

MAX_ROWS_FOR_BATCHGETITEM

public static final int MAX_ROWS_FOR_BATCHGETITEM

See Also:

Constant Field Values

MAX_ROWS_FOR_BATCHWRITER

public static final int MAX_ROWS_FOR_BATCHWRITER

See Also:

Constant Field Values

METADATA_PRIMARY_ID_KEY

public static final String METADATA_PRIMARY_ID_KEY

See Also:

Constant Field Values

METADATA_SECONDARY_ID_KEY

public static final String METADATA_SECONDARY_ID_KEY

See Also:

Constant Field Values

METADATA_TIMESTAMP_KEY

public static final String METADATA_TIMESTAMP_KEY

See Also:

Constant Field Values

METADATA_VISIBILITY_KEY

public static final String METADATA_VISIBILITY_KEY

See Also:

Constant Field Values

METADATA_VALUE_KEY

public static final String METADATA_VALUE_KEY

See Also:

Constant Field Values

tableExistsCache

public static Map<String,Boolean> tableExistsCache

Constructor Detail

DynamoDBOperations

public DynamoDBOperations(DynamoDBOptions options)

Method Detail

createOperations

public static DynamoDBOperations createOperations(DynamoDBOptions options)
                                           throws IOException

Throws:

IOException

getOptions

public DynamoDBOptions getOptions()

getClient

public com.amazonaws.services.dynamodbv2.AmazonDynamoDBAsync getClient()

getQualifiedTableName

public String getQualifiedTableName(String tableName)

getMetadataTableName

public String getMetadataTableName(MetadataType metadataType)

deleteAll

public void deleteAll()
               throws Exception

Specified by:

deleteAll in interface DataStoreOperations

Throws:

Exception

indexExists

public boolean indexExists(String indexName)
                    throws IOException

Specified by:

indexExists in interface DataStoreOperations

Throws:

IOException

deleteAll

public boolean deleteAll(String indexName,
                         String typeName,
                         Short adapterId,
                         String... additionalAuthorizations)

Specified by:

deleteAll in interface DataStoreOperations

ensureAuthorizations

public boolean ensureAuthorizations(String clientUser,
                                    String... authorizations)

Specified by:

ensureAuthorizations in interface DataStoreOperations

createWriter

public RowWriter createWriter(Index index,
                              InternalDataAdapter<?> adapter)

Specified by:

createWriter in interface DataStoreOperations

createDataIndexWriter

public RowWriter createDataIndexWriter(InternalDataAdapter<?> adapter)

Specified by:

createDataIndexWriter in interface DataStoreOperations

delete

public void delete(DataIndexReaderParams readerParams)

Specified by:

delete in interface DataStoreOperations

deleteRowsFromDataIndex

public void deleteRowsFromDataIndex(byte[][] dataIds,
                                    short adapterId,
                                    String typeName)

createReader

public RowReader<GeoWaveRow> createReader(DataIndexReaderParams readerParams)

Specified by:

createReader in interface DataStoreOperations

getRowsFromDataIndex

public Iterator<GeoWaveRow> getRowsFromDataIndex(short adapterId,
                                                 String typeName)

getRowsFromDataIndex

public Iterator<GeoWaveRow> getRowsFromDataIndex(byte[][] dataIds,
                                                 short adapterId,
                                                 String typeName)

createMetadataWriter

public MetadataWriter createMetadataWriter(MetadataType metadataType)

Specified by:

createMetadataWriter in interface DataStoreOperations

createMetadataReader

public MetadataReader createMetadataReader(MetadataType metadataType)

Specified by:

createMetadataReader in interface DataStoreOperations

createMetadataDeleter

public MetadataDeleter createMetadataDeleter(MetadataType metadataType)

Specified by:

createMetadataDeleter in interface DataStoreOperations

createReader

public <T> RowReader<T> createReader(ReaderParams<T> readerParams)

Specified by:

createReader in interface DataStoreOperations

createReader

public RowReader<GeoWaveRow> createReader(RecordReaderParams recordReaderParams)

Specified by:

createReader in interface MapReduceDataStoreOperations

createRowDeleter

public RowDeleter createRowDeleter(String indexName,
                                   PersistentAdapterStore adapterStore,
                                   InternalAdapterStore internalAdapterStore,
                                   String... authorizations)

Specified by:

createRowDeleter in interface DataStoreOperations

metadataExists

public boolean metadataExists(MetadataType type)
                       throws IOException

Specified by:

metadataExists in interface DataStoreOperations

Throws:

IOException

createIndex

public boolean createIndex(Index index)
                    throws IOException

Throws:

IOException