IAccessPathfor a join dimension. Each element in the chunk in paired with a copy of the given bindings. If that
IBindingSetis accepted by the
IRule, then the
IBindingSetwill be output. The
IBindingSets to be output are buffered into chunks and the chunks added to the
JoinPipelineTask#bindingSetBuffersfor the corresponding predicate.
|Constructor and Description|
public JoinTask.ChunkTask(IBindingSet bindingSet, AbstractUnsynchronizedArrayBuffer<IBindingSet> unsyncBuffer, Object chunk)
bindingSet- The bindings with which the each element in the chunk will be paired to create the bindings for the downstream join dimension.
unsyncBuffer- A per-
Threadbuffer used to accumulate chunks of generated
IBindingSets (optional). When the
JoinTask.ChunkTaskwill be run in its own thread, pass
nulland the buffer will be obtained in
chunk- A chunk of elements read from the
IAccessPathfor the current join dimension.
trueiff NO elements in the chunk (as read from the access path by the caller) were accepted when combined with the
bindingSetsfrom the source
BufferClosedException- if there is an attempt to output a chunk of
ISolutions and the output buffer is an
IBlockingBuffer(true for all join dimensions exception the lastJoin and also true for query on the lastJoin) and that
IBlockingBufferhas been closed.
Copyright © 2006–2019 SYSTAP, LLC DBA Blazegraph. All rights reserved.