NodePageStream (Ignite 2.17.0)

java.lang.Object
- org.apache.ignite.internal.processors.cache.query.reducer.NodePageStream<R>

```
public class NodePageStream<R>
extends Object
```
This class provides an interface headPage() that returns a future will be completed with NodePage of cache query result from single node. A new page requests when previous page was fetched by class consumer.

Constructor Summary

Constructors
Constructor Description

NodePageStream(UUID nodeId, Runnable reqPages, Runnable cancelPages)

Method Summary

All Methods Instance Methods Concrete Methods
Modifier and Type	Method	Description
`void`	`addPage(Collection<R> data, boolean last)`	Add new query result page of data.
`void`	`cancel(Throwable err)`	Cancel query on all nodes.
`boolean`	`closed()`
`boolean`	`hasRemotePages()`
`CompletableFuture<NodePage<R>>`	`headPage()`	Returns a last delivered page from this stream.
`UUID`	`nodeId()`

Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

- Constructor Detail
  - NodePageStream
```
public NodePageStream(UUID nodeId,
                      Runnable reqPages,
                      Runnable cancelPages)
```
- Method Detail
  - nodeId
```
public UUID nodeId()
```
  - headPage
```
public CompletableFuture<NodePage<R>> headPage()
```
    Returns a last delivered page from this stream.
    
    Returns:
    
    Future that will be completed with query result page.
  - addPage
```
public void addPage(Collection<R> data,
                    boolean last)
```
    Add new query result page of data.
    
    Parameters:
    
    data - Collection of query result items.
    
    last - Whether it is the last page from this node.
  - cancel
```
public void cancel(Throwable err)
```
    Cancel query on all nodes.
  - hasRemotePages
```
public boolean hasRemotePages()
```
    Returns:
    
    true if there are some undelivered page from the node, otherwise false.
  - closed
```
public boolean closed()
```
    Returns:
    
    true if this stream delivers all query results from the node to a consumer.