org.locationtech.geowave.datastore.dynamodb.operations

Class DynamoDBWriter

java.lang.Object

org.locationtech.geowave.datastore.dynamodb.operations.DynamoDBWriter

All Implemented Interfaces:

AutoCloseable, RowWriter

public class DynamoDBWriter
extends Object
implements RowWriter

Constructor Summary

Constructors

Constructor and Description
DynamoDBWriter(com.amazonaws.services.dynamodbv2.AmazonDynamoDBAsync client, String tableName, boolean isDataIndex)

Method Summary

Modifier and Type	Method and Description
void	close()
void	flush() Flush the writer, committing all pending writes.
void	write(GeoWaveRow row) Write a GeoWave row to the DB.
void	write(GeoWaveRow[] rows) Write multiple GeoWave rows to the DB.
void	write(Iterable<com.amazonaws.services.dynamodbv2.model.WriteRequest> items)
void	write(com.amazonaws.services.dynamodbv2.model.WriteRequest item)

Methods inherited from class java.lang.Object

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

Constructor Detail

DynamoDBWriter

public DynamoDBWriter(com.amazonaws.services.dynamodbv2.AmazonDynamoDBAsync client,
                      String tableName,
                      boolean isDataIndex)

Method Detail

close

public void close()
           throws IOException

Specified by:

close in interface AutoCloseable

Throws:

IOException

write

public void write(GeoWaveRow[] rows)

Description copied from interface: RowWriter

Write multiple GeoWave rows to the DB. Preconditions:

• The writer is not closed

Specified by:

write in interface RowWriter

Parameters:

rows - The array of rows to be written.

write

public void write(GeoWaveRow row)

Description copied from interface: RowWriter

Write a GeoWave row to the DB. Preconditions:

• The writer is not closed

Specified by:

write in interface RowWriter

Parameters:

row - The row to be written.

write

public void write(Iterable<com.amazonaws.services.dynamodbv2.model.WriteRequest> items)

write

public void write(com.amazonaws.services.dynamodbv2.model.WriteRequest item)

flush

public void flush()

Description copied from interface: RowWriter

Flush the writer, committing all pending writes. Note that the writes may already be committed - this method just establishes that they *must* be committed after the method returns. Preconditions:

• The writer is not closed

Specified by:

flush in interface RowWriter