org.locationtech.geowave.datastore.bigtable.operations

Class BigtableReader<T>

java.lang.Object

org.locationtech.geowave.datastore.hbase.operations.HBaseReader<T>

org.locationtech.geowave.datastore.bigtable.operations.BigtableReader<T>

All Implemented Interfaces:

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

public class BigtableReader<T>
extends HBaseReader<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 inherited from class org.locationtech.geowave.datastore.hbase.operations.HBaseReader

operations, readerParams, scanner

Constructor Summary

Constructors

Constructor and Description
BigtableReader(ReaderParams<T> readerParams, HBaseOperations operations)
BigtableReader(RecordReaderParams recordReaderParams, HBaseOperations operations)

Method Summary

Modifier and Type	Method and Description
protected Iterator<T>	getScanIterator(Iterator<org.apache.hadoop.hbase.client.Result> iterable)

Methods inherited from class org.locationtech.geowave.datastore.hbase.operations.HBaseReader

close, getMultiScanner, hasNext, initRecordScanner, initScanner, next

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

Constructor Detail

BigtableReader

public BigtableReader(ReaderParams<T> readerParams,
                      HBaseOperations operations)

BigtableReader

public BigtableReader(RecordReaderParams recordReaderParams,
                      HBaseOperations operations)

Method Detail

getScanIterator

protected Iterator<T> getScanIterator(Iterator<org.apache.hadoop.hbase.client.Result> iterable)

Overrides:

getScanIterator in class HBaseReader<T>