Module org.apache.jena.serviceplugins

Package org.apache.jena.sparql.service.enhancer.impl

Class RequestExecutor

java.lang.Object

org.apache.jena.atlas.iterator.IteratorSlotted<org.apache.jena.sparql.engine.binding.Binding>

org.apache.jena.sparql.service.enhancer.impl.util.QueryIterSlottedBase

org.apache.jena.sparql.service.enhancer.impl.RequestExecutor

All Implemented Interfaces:

Iterator<org.apache.jena.sparql.engine.binding.Binding>, org.apache.jena.atlas.io.Printable, org.apache.jena.atlas.iterator.IteratorCloseable<org.apache.jena.sparql.engine.binding.Binding>, org.apache.jena.atlas.lib.Closeable, org.apache.jena.sparql.engine.QueryIterator, org.apache.jena.sparql.util.PrintSerializable

public class RequestExecutor
extends QueryIterSlottedBase

Prepare and execute bulk requests

Constructor Summary

Constructors

Constructor	Description
RequestExecutor(OpServiceExecutorImpl opExector, OpServiceInfo serviceInfo, ServiceResultSizeCache resultSizeCache, ServiceResponseCache cache, CacheMode cacheMode, org.apache.jena.atlas.iterator.IteratorCloseable<GroupedBatch<org.apache.jena.graph.Node,Long,org.apache.jena.sparql.engine.binding.Binding>> batchIterator)

Method Summary

Modifier and Type	Method	Description
void	prepareNextBatchExec()	Prepare the lazy execution of the next batch and register all iterators with inputToOutputIt

Methods inherited from class org.apache.jena.sparql.service.enhancer.impl.util.QueryIterSlottedBase

cancel, nextBinding, output, output, toString, toString

Methods inherited from class org.apache.jena.atlas.iterator.IteratorSlotted

close, hasNext, next, peek, peek

Methods inherited from class java.lang.Object

equals, getClass, hashCode, notify, notifyAll, wait, wait, wait

Methods inherited from interface org.apache.jena.atlas.lib.Closeable

close

Methods inherited from interface java.util.Iterator

forEachRemaining, hasNext, next, remove

Methods inherited from interface org.apache.jena.sparql.engine.QueryIterator

isJoinIdentity

Constructor Details

RequestExecutor

public RequestExecutor(OpServiceExecutorImpl opExector,
 OpServiceInfo serviceInfo,
 ServiceResultSizeCache resultSizeCache,
 ServiceResponseCache cache,
 CacheMode cacheMode,
 org.apache.jena.atlas.iterator.IteratorCloseable<GroupedBatch<org.apache.jena.graph.Node,Long,org.apache.jena.sparql.engine.binding.Binding>> batchIterator)

Method Details

prepareNextBatchExec

public void prepareNextBatchExec()

Prepare the lazy execution of the next batch and register all iterators with inputToOutputIt