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
ConstructorsConstructorDescriptionOExecutionStreamDistributedFetch(String queryId, String nodeName, OExecutionStream first, ODatabaseDocumentDistributed db) -
Method Summary
Modifier and TypeMethodDescriptionvoidclose(OCommandContext ctx) booleanhasNext(OCommandContext ctx) next(OCommandContext ctx)
-
Constructor Details
-
OExecutionStreamDistributedFetch
public OExecutionStreamDistributedFetch(String queryId, String nodeName, OExecutionStream first, ODatabaseDocumentDistributed db)
-
-
Method Details
-
next
- Specified by:
nextin interfaceOExecutionStreamProducer
-
hasNext
- Specified by:
hasNextin interfaceOExecutionStreamProducer
-
close
- Specified by:
closein interfaceOExecutionStreamProducer
-