Package com.orientechnologies.orient.server.distributed.impl.task

Class OExecutionStreamDistributedFetch

java.lang.Object

com.orientechnologies.orient.server.distributed.impl.task.OExecutionStreamDistributedFetch

All Implemented Interfaces:

OExecutionStreamProducer

public final class OExecutionStreamDistributedFetch
extends Object
implements OExecutionStreamProducer

Constructor Summary

Constructors

Constructor	Description
OExecutionStreamDistributedFetch(String queryId, String nodeName, OExecutionStream first, ODatabaseDocumentDistributed db)

Method Summary

Modifier and Type	Method	Description
void	close(OCommandContext ctx)
boolean	hasNext(OCommandContext ctx)
OExecutionStream	next(OCommandContext ctx)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Details

OExecutionStreamDistributedFetch

public OExecutionStreamDistributedFetch(String queryId,
 String nodeName,
 OExecutionStream first,
 ODatabaseDocumentDistributed db)

Method Details

next

public OExecutionStream next(OCommandContext ctx)

Specified by:

next in interface OExecutionStreamProducer

hasNext

public boolean hasNext(OCommandContext ctx)

Specified by:

hasNext in interface OExecutionStreamProducer

close

public void close(OCommandContext ctx)

Specified by:

close in interface OExecutionStreamProducer