Skip to content

Commit 7c72ba9

Browse files
committed
working on new ID based join iterator
1 parent 353965c commit 7c72ba9

1 file changed

Lines changed: 15 additions & 12 deletions

File tree

core/sail/lmdb/src/main/java/org/eclipse/rdf4j/sail/lmdb/join/LmdbIdBGPQueryEvaluationStep.java

Lines changed: 15 additions & 12 deletions
Original file line numberDiff line numberDiff line change
@@ -13,7 +13,10 @@
1313
import java.io.IOException;
1414
import java.util.ArrayList;
1515
import java.util.Arrays;
16+
import java.util.Collections;
17+
import java.util.HashMap;
1618
import java.util.List;
19+
import java.util.Map;
1720
import java.util.Optional;
1821

1922
import org.eclipse.rdf4j.common.iteration.CloseableIteration;
@@ -54,7 +57,7 @@ public final class LmdbIdBGPQueryEvaluationStep implements QueryEvaluationStep {
5457
private final boolean hasInvalidPattern;
5558
private final boolean createdDynamicIds;
5659
private final boolean allowCreateConstantIds;
57-
private final java.util.Map<String, Long> constantBindings;
60+
private final Map<String, Long> constantBindings;
5861

5962
public LmdbIdBGPQueryEvaluationStep(Join root, List<StatementPattern> patterns, QueryEvaluationContext context,
6063
QueryEvaluationStep fallbackStep) {
@@ -81,7 +84,7 @@ public LmdbIdBGPQueryEvaluationStep(Join root, List<StatementPattern> patterns,
8184
List<RawPattern> rawPatterns = new ArrayList<>(patterns.size());
8285
boolean invalid = false;
8386
boolean created = false;
84-
java.util.Map<String, Long> constants = new java.util.HashMap<>();
87+
Map<String, Long> constants = new HashMap<>();
8588
for (StatementPattern pattern : patterns) {
8689
RawPattern raw = RawPattern.create(pattern, valueStore, allowCreate);
8790
rawPatterns.add(raw);
@@ -91,7 +94,7 @@ public LmdbIdBGPQueryEvaluationStep(Join root, List<StatementPattern> patterns,
9194
}
9295
this.hasInvalidPattern = invalid;
9396
this.createdDynamicIds = created;
94-
this.constantBindings = java.util.Collections.unmodifiableMap(constants);
97+
this.constantBindings = Collections.unmodifiableMap(constants);
9598

9699
if (rawPatterns.isEmpty()) {
97100
throw new IllegalArgumentException("Basic graph pattern must contain at least one statement pattern");
@@ -164,7 +167,7 @@ public CloseableIteration<BindingSet> evaluate(BindingSet bindings) {
164167
}
165168

166169
private LmdbEvaluationDataset resolveDataset() {
167-
java.util.Optional<LmdbEvaluationDataset> fromContext = datasetContext.getLmdbDataset();
170+
Optional<LmdbEvaluationDataset> fromContext = datasetContext.getLmdbDataset();
168171
if (fromContext.isPresent()) {
169172
return fromContext.get();
170173
}
@@ -200,8 +203,8 @@ private static long resolveId(ValueStore valueStore, Value value) throws QueryEv
200203
if (value == null) {
201204
return LmdbValue.UNKNOWN_ID;
202205
}
203-
if (value instanceof org.eclipse.rdf4j.sail.lmdb.model.LmdbValue) {
204-
org.eclipse.rdf4j.sail.lmdb.model.LmdbValue lmdbValue = (org.eclipse.rdf4j.sail.lmdb.model.LmdbValue) value;
206+
if (value instanceof LmdbValue) {
207+
LmdbValue lmdbValue = (LmdbValue) value;
205208
if (lmdbValue.getValueStoreRevision().getValueStore() == valueStore) {
206209
long id = lmdbValue.getInternalID();
207210
if (id != LmdbValue.UNKNOWN_ID) {
@@ -310,11 +313,11 @@ private static final class RawPattern {
310313
private final LmdbIdJoinIterator.PatternInfo patternInfo;
311314
private final boolean invalid;
312315
private final boolean createdIds;
313-
private final java.util.Map<String, Long> constantIds;
316+
private final Map<String, Long> constantIds;
314317

315318
private RawPattern(long[] patternIds, String subjVar, String predVar, String objVar, String ctxVar,
316319
LmdbIdJoinIterator.PatternInfo patternInfo, boolean invalid, boolean createdIds,
317-
java.util.Map<String, Long> constantIds) {
320+
Map<String, Long> constantIds) {
318321
this.patternIds = patternIds;
319322
this.subjVar = subjVar;
320323
this.predVar = predVar;
@@ -326,7 +329,7 @@ private RawPattern(long[] patternIds, String subjVar, String predVar, String obj
326329
this.constantIds = constantIds;
327330
}
328331

329-
java.util.Map<String, Long> getConstantIds() {
332+
Map<String, Long> getConstantIds() {
330333
return constantIds;
331334
}
332335

@@ -336,7 +339,7 @@ static RawPattern create(StatementPattern pattern, ValueStore valueStore, boolea
336339

337340
boolean invalid = false;
338341
boolean createdAny = false;
339-
java.util.Map<String, Long> constantIds = new java.util.HashMap<>();
342+
Map<String, Long> constantIds = new HashMap<>();
340343

341344
Var subj = pattern.getSubjectVar();
342345
String subjVar = null;
@@ -431,8 +434,8 @@ private static ConstantIdResult constantId(ValueStore valueStore, Value value, b
431434
return ConstantIdResult.invalid();
432435
}
433436
try {
434-
if (value instanceof org.eclipse.rdf4j.sail.lmdb.model.LmdbValue) {
435-
org.eclipse.rdf4j.sail.lmdb.model.LmdbValue lmdbValue = (org.eclipse.rdf4j.sail.lmdb.model.LmdbValue) value;
437+
if (value instanceof LmdbValue) {
438+
LmdbValue lmdbValue = (LmdbValue) value;
436439
if (lmdbValue.getValueStoreRevision().getValueStore() == valueStore) {
437440
long id = lmdbValue.getInternalID();
438441
if (id != LmdbValue.UNKNOWN_ID) {

0 commit comments

Comments
 (0)