Module org.apache.jena.serviceplugins

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

Class QueryIterWrapperCache

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

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

Constructor Summary

Constructors

Constructor	Description
QueryIterWrapperCache(org.apache.jena.sparql.engine.QueryIterator qIter, int batchSize, ServiceResponseCache cache, ServiceCacheKeyFactory cacheKeyFactory, org.apache.jena.sparql.service.enhancer.impl.Batch<Integer,PartitionRequest<org.apache.jena.sparql.engine.binding.Binding>> inputBatch, org.apache.jena.sparql.core.Var idxVar, org.apache.jena.graph.Node serviceNode)

Method Summary

Modifier and Type	Method	Description
void	prepareNextBatch()	The tricky part is that we first need to consume rhs and write it to the cache.

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

QueryIterWrapperCache

public QueryIterWrapperCache(org.apache.jena.sparql.engine.QueryIterator qIter,
 int batchSize,
 ServiceResponseCache cache,
 ServiceCacheKeyFactory cacheKeyFactory,
 org.apache.jena.sparql.service.enhancer.impl.Batch<Integer,PartitionRequest<org.apache.jena.sparql.engine.binding.Binding>> inputBatch,
 org.apache.jena.sparql.core.Var idxVar,
 org.apache.jena.graph.Node serviceNode)

Method Details

prepareNextBatch

public void prepareNextBatch()

The tricky part is that we first need to consume rhs and write it to the cache. When rhs is consumed a post-action that updates slice metadata has to be performed; but this action depends on the next item in lhs.