public class HashJoinIteration extends LookAheadIteration<BindingSet,QueryEvaluationException>
| Modifier and Type | Field and Description |
|---|---|
protected String[] |
joinAttributes |
| Constructor and Description |
|---|
HashJoinIteration(EvaluationStrategy strategy,
CloseableIteration<BindingSet,QueryEvaluationException> leftIter,
Set<String> leftBindingNames,
CloseableIteration<BindingSet,QueryEvaluationException> rightIter,
Set<String> rightBindingNames,
boolean leftJoin) |
HashJoinIteration(EvaluationStrategy strategy,
Join join,
BindingSet bindings) |
HashJoinIteration(EvaluationStrategy strategy,
LeftJoin join,
BindingSet bindings) |
HashJoinIteration(EvaluationStrategy strategy,
TupleExpr left,
TupleExpr right,
BindingSet bindings,
boolean leftJoin) |
| Modifier and Type | Method and Description |
|---|---|
protected <E> void |
add(Collection<E> col,
E value) |
protected <E> void |
addAll(Collection<E> col,
List<E> values) |
protected <E> void |
closeHashValue(Iterator<E> iter)
Utility methods to clear-up in case not using in-memory hash table.
|
protected void |
disposeCache(Iterator<BindingSet> iter)
Utility methods to clear-up in case not using in-memory cache.
|
protected void |
disposeHashTable(Map<BindingSetHashKey,List<BindingSet>> map)
Utility methods to clear-up in case not using in-memory hash table.
|
protected BindingSet |
getNextElement()
Gets the next element.
|
protected void |
handleClose()
Called by
AbstractCloseableIteration.close() when it is called for the first time. |
protected Map<BindingSetHashKey,List<BindingSet>> |
makeHashTable(int initialSize)
Utility methods to make it easier to inserted custom store dependent maps
|
protected List<BindingSet> |
makeHashValue(int currentMaxListSize)
Utility methods to make it easier to inserted custom store dependent list
|
protected Collection<BindingSet> |
makeIterationCache(CloseableIteration<BindingSet,QueryEvaluationException> iter)
Utility methods to make it easier to inserted custom store dependent list
|
protected <E> E |
nextFromCache(Iterator<E> iter) |
protected void |
putHashTableEntry(Map<BindingSetHashKey,List<BindingSet>> nextHashTable,
BindingSetHashKey hashKey,
List<BindingSet> hashValue,
boolean newEntry) |
hasNext, next, removeclose, isClosedprotected final String[] joinAttributes
public HashJoinIteration(EvaluationStrategy strategy, Join join, BindingSet bindings) throws QueryEvaluationException
QueryEvaluationExceptionpublic HashJoinIteration(EvaluationStrategy strategy, LeftJoin join, BindingSet bindings) throws QueryEvaluationException
QueryEvaluationExceptionpublic HashJoinIteration(EvaluationStrategy strategy, TupleExpr left, TupleExpr right, BindingSet bindings, boolean leftJoin) throws QueryEvaluationException
QueryEvaluationExceptionpublic HashJoinIteration(EvaluationStrategy strategy, CloseableIteration<BindingSet,QueryEvaluationException> leftIter, Set<String> leftBindingNames, CloseableIteration<BindingSet,QueryEvaluationException> rightIter, Set<String> rightBindingNames, boolean leftJoin) throws QueryEvaluationException
QueryEvaluationExceptionprotected BindingSet getNextElement() throws QueryEvaluationException
LookAheadIterationgetNextElement in class LookAheadIteration<BindingSet,QueryEvaluationException>QueryEvaluationExceptionprotected void handleClose()
throws QueryEvaluationException
AbstractCloseableIterationAbstractCloseableIteration.close() when it is called for the first time. This method is only called once on each iteration.
By default, this method does nothing.handleClose in class LookAheadIteration<BindingSet,QueryEvaluationException>QueryEvaluationExceptionprotected void putHashTableEntry(Map<BindingSetHashKey,List<BindingSet>> nextHashTable, BindingSetHashKey hashKey, List<BindingSet> hashValue, boolean newEntry) throws QueryEvaluationException
QueryEvaluationExceptionprotected Collection<BindingSet> makeIterationCache(CloseableIteration<BindingSet,QueryEvaluationException> iter)
protected Map<BindingSetHashKey,List<BindingSet>> makeHashTable(int initialSize)
protected List<BindingSet> makeHashValue(int currentMaxListSize)
protected void disposeCache(Iterator<BindingSet> iter)
protected void disposeHashTable(Map<BindingSetHashKey,List<BindingSet>> map)
protected <E> void closeHashValue(Iterator<E> iter)
protected <E> E nextFromCache(Iterator<E> iter)
protected <E> void add(Collection<E> col, E value) throws QueryEvaluationException
QueryEvaluationExceptionprotected <E> void addAll(Collection<E> col, List<E> values) throws QueryEvaluationException
QueryEvaluationExceptionCopyright © 2015-2021 Eclipse Foundation. All Rights Reserved.