org.apache.ignite.internal.processors.cache.query.reducer

Class NodePageStream<R>

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 and Description
NodePageStream(UUID nodeId, Runnable reqPages, Runnable cancelPages)

Method Summary

Modifier and Type	Method and 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.