org.locationtech.geowave.datastore.rocksdb.operations

Class RocksDBWriter

java.lang.Object

org.locationtech.geowave.datastore.rocksdb.operations.RocksDBWriter

All Implemented Interfaces:

AutoCloseable, RowWriter

public class RocksDBWriter
extends Object
implements RowWriter

Constructor Summary

Constructors

Constructor and Description
RocksDBWriter(RocksDBClient client, short adapterId, String typeName, String indexName, boolean isTimestampRequired)

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.

Methods inherited from class java.lang.Object

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

Constructor Detail

RocksDBWriter

public RocksDBWriter(RocksDBClient client,
                     short adapterId,
                     String typeName,
                     String indexName,
                     boolean isTimestampRequired)

Method Detail

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.

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

close

public void close()

Specified by:

close in interface AutoCloseable