org.locationtech.geowave.datastore.kudu.operations

Class KuduWriter

java.lang.Object

org.locationtech.geowave.datastore.kudu.operations.KuduWriter

All Implemented Interfaces:

AutoCloseable, RowWriter

public class KuduWriter
extends Object
implements RowWriter

Constructor Summary

Constructors

Constructor and Description
KuduWriter(String tableName, KuduOperations 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

KuduWriter

public KuduWriter(String tableName,
                  KuduOperations operations)

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()
           throws Exception

Specified by:

close in interface AutoCloseable

Throws:

Exception