Module org.apache.jena.serviceplugins

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

Class QueryIterServiceBulk

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.QueryIterServiceBulk

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 QueryIterServiceBulk
extends QueryIterSlottedBase

QueryIter to process service requests in bulk with support for streaming caching. The methods closeIterator and moveToNext are synchronized.

Constructor Summary

Constructors

Constructor	Description
QueryIterServiceBulk(OpServiceInfo serviceInfo, BatchQueryRewriter batchQueryRewriter, ServiceCacheKeyFactory cacheKeyFactory, OpServiceExecutor opExecutor, org.apache.jena.sparql.engine.ExecutionContext execCxt, List<org.apache.jena.sparql.engine.binding.Binding> inputs, ServiceResultSizeCache resultSizeCache, ServiceResponseCache cache, CacheMode cacheMode)

Method Summary

Modifier and Type	Method	Description
void	closeIterator()
org.apache.jena.sparql.core.Var	getIdxVar()
SliceKey	getPartKeyFromBinding(org.apache.jena.sparql.engine.binding.Binding binding)
void	prepareNextBatchExec(boolean bypassCacheOnFirstInput)	Prepare the lazy execution of the next batch and register all iterators with sliceKeyToIter

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

QueryIterServiceBulk

public QueryIterServiceBulk(OpServiceInfo serviceInfo,
 BatchQueryRewriter batchQueryRewriter,
 ServiceCacheKeyFactory cacheKeyFactory,
 OpServiceExecutor opExecutor,
 org.apache.jena.sparql.engine.ExecutionContext execCxt,
 List<org.apache.jena.sparql.engine.binding.Binding> inputs,
 ServiceResultSizeCache resultSizeCache,
 ServiceResponseCache cache,
 CacheMode cacheMode)

Method Details

getIdxVar

public org.apache.jena.sparql.core.Var getIdxVar()

getPartKeyFromBinding

public SliceKey getPartKeyFromBinding(org.apache.jena.sparql.engine.binding.Binding binding)

closeIterator

public void closeIterator()

prepareNextBatchExec

public void prepareNextBatchExec(boolean bypassCacheOnFirstInput)

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