public class HBaseScanIterator extends AbstractIterator<Record> implements Closeable
Constructor and Description |
---|
HBaseScanIterator(AbstractHBaseUtils hbaseUtils,
String tableName,
String familyName,
XPath condition,
Iterable<? extends org.openrdf.model.URI> properties,
boolean localFiltering)
Creates a new
HBaseScanStream based on the parameters supplied. |
Modifier and Type | Method and Description |
---|---|
void |
close()
Closes the HBase scanner, if previousy created.
|
protected Record |
computeNext() |
endOfData, hasNext, next, peek
remove
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
forEachRemaining
public HBaseScanIterator(AbstractHBaseUtils hbaseUtils, String tableName, String familyName, @Nullable XPath condition, @Nullable Iterable<? extends org.openrdf.model.URI> properties, boolean localFiltering) throws IOException
HBaseScanStream
based on the parameters supplied.hbaseUtils
- the AbstractHBaseUtils
object for accessing HBase, not nulltableName
- the name of the HBase table to access, not nullfamilyName
- the name of the HBase column family to access, not nullcondition
- optional condition to be satisfied by matching records, possibly nullproperties
- properties to return, null if all properties are requestedlocalFiltering
- true if filtering should be performed locally to the HBase clientIOException
- on failureprotected Record computeNext()
computeNext
in class AbstractIterator<Record>
public void close()
close
in interface Closeable
close
in interface AutoCloseable
Copyright © 2015–2016 FBK-irst. All rights reserved.