IncomingResultSet

IncomingResultSet is an interface for retrieving rows as List<Object> from an incoming result set.

This interface uses semantics similar to a BlockingQueue. It has these methods:

Method Description
takeRow() Retrieve and removes the head row in this result set as a List<Object>, waiting if necessary until an element becomes available, or returning END_OF_RESULTS if there are no more rows in this result set.
pollRow() Retrieves and removes the head row of this result set, returns null if there is no row currently available in this result set, or returns END_OF_RESULTS if there are no more rows in this result set.
pollRow(long timeout, TimeUnit unit) An overload of above with a timeout parameter. The TimeUnit parameter is used to interpret the timeout parameter.
peekRow() Retrieves, but does not remove, the head row of this result set, returns null if there is no row currently available in this result set, or returns END_OF_RESULTS if there are no more rows in this result set.
peekRow(long timeout, TimeUnit unit) An overload of above with a timeout parameter.
waitPeekRow() Retrieves, but does not remove, the head row of this result set, waiting if necessary until an element becomes available, or returning END_OF_RESULTS if there are no more rows in this result set.
getMetaData() Return metadata information about the columns in this result set. May block until the metadata is available.