org.locationtech.geowave.datastore.hbase.operations

Class HBaseMetadataWriter

java.lang.Object

org.locationtech.geowave.datastore.hbase.operations.HBaseMetadataWriter

All Implemented Interfaces:

AutoCloseable, MetadataWriter

public class HBaseMetadataWriter
extends Object
implements MetadataWriter

Field Summary

Fields

Modifier and Type	Field and Description
protected Set<ByteArray>	duplicateRowTracker

Constructor Summary

Constructors

Constructor and Description
HBaseMetadataWriter(org.apache.hadoop.hbase.client.BufferedMutator writer, MetadataType metadataType)

Method Summary

Modifier and Type	Method and Description
void	close()
void	flush() Flush the writer, committing all pending writes.
void	write(GeoWaveMetadata metadata) Write metadata to the table.

Methods inherited from class java.lang.Object

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

Field Detail

duplicateRowTracker

protected Set<ByteArray> duplicateRowTracker

Constructor Detail

HBaseMetadataWriter

public HBaseMetadataWriter(org.apache.hadoop.hbase.client.BufferedMutator writer,
                           MetadataType metadataType)

Method Detail

close

public void close()
           throws Exception

Specified by:

close in interface AutoCloseable

Throws:

Exception

flush

public void flush()

Description copied from interface: MetadataWriter

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 MetadataWriter

write

public void write(GeoWaveMetadata metadata)

Description copied from interface: MetadataWriter

Write metadata to the table. Preconditions:

• The writer is not closed

Specified by:

write in interface MetadataWriter

Parameters:

metadata - The metadata.