org.locationtech.geowave.datastore.cassandra.operations

Class CassandraWriter

java.lang.Object

org.locationtech.geowave.datastore.cassandra.operations.CassandraWriter

All Implemented Interfaces:

AutoCloseable, RowWriter

public class CassandraWriter
extends Object
implements RowWriter

Constructor Summary

Constructors

Constructor and Description
CassandraWriter(String tableName, CassandraOperations operations)

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

CassandraWriter

public CassandraWriter(String tableName,
                       CassandraOperations operations)

Method Detail

close

public void close()
           throws Exception

Specified by:

close in interface AutoCloseable

Throws:

Exception

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