org.apache.kudu.client

Class RowResultIterator

java.lang.Object

org.apache.kudu.client.RowResultIterator

All Implemented Interfaces:

Iterable<RowResult>, Iterator<RowResult>

@InterfaceAudience.Public
 @InterfaceStability.Evolving
public abstract class RowResultIterator
extends Object
implements Iterator<RowResult>, Iterable<RowResult>

Class that contains the rows sent by a tablet server, exhausting this iterator only means that all the rows from the last server response were read.

Field Summary

Fields

Modifier and Type	Field and Description
protected int	currentRow
protected int	numRows
protected Schema	schema

Constructor Summary

Constructors

Modifier	Constructor and Description
protected	RowResultIterator(long elapsedMillis, String tsUUID, Schema schema, int numRows, boolean reuseRowResult) Package private constructor, only meant to be instantiated from AsyncKuduScanner.

Method Summary

Modifier and Type	Method and Description
static RowResultIterator	empty()
long	getElapsedMillis() Get the number of milliseconds elapsed since the RPC was created up to the moment when this response was created.
int	getNumRows()
String	getTsUUID() Get the identifier of the tablet server that sent the response.
boolean	hasNext()
Iterator<RowResult>	iterator()
void	remove()

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, next

Methods inherited from interface java.lang.Iterable

forEach, spliterator

Field Detail

schema

protected final Schema schema

numRows

protected final int numRows

currentRow

protected int currentRow

Constructor Detail

RowResultIterator

protected RowResultIterator(long elapsedMillis,
                            String tsUUID,
                            Schema schema,
                            int numRows,
                            boolean reuseRowResult)

Package private constructor, only meant to be instantiated from AsyncKuduScanner.

Parameters:

elapsedMillis - time in milliseconds since RPC creation to now

tsUUID - UUID of the tablet server that handled our request

schema - schema used to parse the rows

numRows - how many rows are contained in the bs slice

Method Detail

getNumRows

public int getNumRows()

empty

public static RowResultIterator empty()

hasNext

public boolean hasNext()

Specified by:

hasNext in interface Iterator<RowResult>

remove

public void remove()

Specified by:

remove in interface Iterator<RowResult>

iterator

public Iterator<RowResult> iterator()

Specified by:

iterator in interface Iterable<RowResult>

getElapsedMillis

public long getElapsedMillis()

Get the number of milliseconds elapsed since the RPC was created up to the moment when this response was created.

Returns:

elapsed time in milliseconds

getTsUUID

public String getTsUUID()

Get the identifier of the tablet server that sent the response. May be null if the RPC failed before tablet location lookup succeeded.

Returns:

a string containing a UUID