org.locationtech.geowave.datastore.rocksdb.util

Class AbstractRocksDBIterator<T>

java.lang.Object

org.locationtech.geowave.datastore.rocksdb.util.AbstractRocksDBIterator<T>

All Implemented Interfaces:

Closeable, AutoCloseable, Iterator<T>, CloseableIterator<T>

Direct Known Subclasses:

DataIndexForwardRowIterator, RocksDBMetadataIterator, RocksDBRowIterator

public abstract class AbstractRocksDBIterator<T>
extends Object
implements CloseableIterator<T>

Nested Class Summary

Nested classes/interfaces inherited from interface org.locationtech.geowave.core.store.CloseableIterator

CloseableIterator.Empty<E>, CloseableIterator.Wrapper<E>

Field Summary

Fields

Modifier and Type	Field and Description
protected boolean	closed
protected org.rocksdb.RocksIterator	it
protected org.rocksdb.ReadOptions	options

Constructor Summary

Constructors

Constructor and Description
AbstractRocksDBIterator(org.rocksdb.ReadOptions options, org.rocksdb.RocksIterator it)

Method Summary

Modifier and Type	Method and Description
protected void	advance()
void	close()
boolean	hasNext()
T	next()
protected abstract T	readRow(byte[] key, byte[] value)

Methods inherited from class java.lang.Object

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

Methods inherited from interface java.util.Iterator

forEachRemaining, remove

Field Detail

closed

protected boolean closed

options

protected org.rocksdb.ReadOptions options

it

protected org.rocksdb.RocksIterator it

Constructor Detail

AbstractRocksDBIterator

public AbstractRocksDBIterator(org.rocksdb.ReadOptions options,
                               org.rocksdb.RocksIterator it)

Method Detail

hasNext

public boolean hasNext()

Specified by:

hasNext in interface Iterator<T>

next

public T next()

Specified by:

next in interface Iterator<T>

advance

protected void advance()

readRow

protected abstract T readRow(byte[] key,
                             byte[] value)

close

public void close()

Specified by:

close in interface Closeable

Specified by:

close in interface AutoCloseable

Specified by:

close in interface CloseableIterator<T>