@InterfaceAudience.Public @InterfaceStability.Evolving public class KuduScanner extends Object
AsyncKuduScanner
. Offers the same API but with blocking methods.Modifier and Type | Class and Description |
---|---|
static class |
KuduScanner.KuduScannerBuilder
A Builder class to build
KuduScanner . |
Modifier and Type | Method and Description |
---|---|
RowResultIterator |
close()
Closes this scanner (don't forget to call this when you're done with it!).
|
long |
getBatchSizeBytes()
Returns the maximum number of bytes returned by the scanner, on each batch.
|
boolean |
getCacheBlocks()
Returns if this scanner was configured to cache data blocks or not.
|
long |
getLimit()
Returns the maximum number of rows that this scanner was configured to return.
|
Schema |
getProjectionSchema()
Returns the projection schema of this scanner.
|
AsyncKuduScanner.ReadMode |
getReadMode()
Returns the ReadMode for this scanner.
|
boolean |
hasMoreRows()
Tells if the last rpc returned that there might be more rows to scan.
|
RowResultIterator |
nextRows()
Scans a number of rows.
|
public boolean hasMoreRows()
public RowResultIterator nextRows() throws Exception
Once this method returns null
once (which indicates that this
Scanner
is done scanning), calling it again leads to an undefined
behavior.
Exception
public RowResultIterator close() throws Exception
Closing a scanner already closed has no effect.
Exception
public long getLimit()
public boolean getCacheBlocks()
public long getBatchSizeBytes()
public AsyncKuduScanner.ReadMode getReadMode()
public Schema getProjectionSchema()
Copyright © 2016. All rights reserved.