GemFire XD API / Procedure Result Processor Interfaces |
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. |