- All Implemented Interfaces:
org.apache.jena.atlas.lib.Copyable<TripleStore>
,TripleStore
Internal structure: - One indexed hash set (same as GraphMem2Fast uses) that holds all triples - Three hash maps indexed by subjects, predicates, and objects with RoaringBitmaps as values - The bitmaps contain the indices of the triples in the central hash set
The bitmaps are used to quickly find triples that match a given pattern.
The bitmaps operations like FastAggregation.naive_and(RoaringBitmap...)
and
RoaringBitmap.intersects(RoaringBitmap, RoaringBitmap)
are used to find matches for the pattern
S_O, SP_, and _PO pretty fast, even in large graphs.
Additional optimizations:
- because we know that if a triple exists in one of the maps, it also exists in the other two, we can use the
JenaMapSetCommon.removeUnchecked(java.lang.Object)
method to avoid
unnecessary checks.
-
Constructor Summary
-
Method Summary
Modifier and TypeMethodDescriptionvoid
Add a triple to the map.void
clear()
Remove all triples from the map.boolean
Answer true if the graph contains any triple matchingt
.copy()
Return a new triple store that is a copy of this one.int
Return the number of triples in the map.Returns anExtendedIterator
of all triples in the graph matching the given triple match.boolean
isEmpty()
Return true if the map is empty.void
Remove a triple from the map.stream()
Returns aStream
of all triples in the graph.Returns aStream
of Triples matching the given pattern.
-
Constructor Details
-
RoaringTripleStore
public RoaringTripleStore()
-
-
Method Details
-
add
Description copied from interface:TripleStore
Add a triple to the map.- Specified by:
add
in interfaceTripleStore
- Parameters:
triple
- to add
-
remove
Description copied from interface:TripleStore
Remove a triple from the map.- Specified by:
remove
in interfaceTripleStore
- Parameters:
triple
- to remove
-
clear
public void clear()Description copied from interface:TripleStore
Remove all triples from the map.- Specified by:
clear
in interfaceTripleStore
-
countTriples
public int countTriples()Description copied from interface:TripleStore
Return the number of triples in the map.- Specified by:
countTriples
in interfaceTripleStore
-
isEmpty
public boolean isEmpty()Description copied from interface:TripleStore
Return true if the map is empty.- Specified by:
isEmpty
in interfaceTripleStore
-
contains
Description copied from interface:TripleStore
Answer true if the graph contains any triple matchingt
.- Specified by:
contains
in interfaceTripleStore
- Parameters:
tripleMatch
- triple match pattern, which may be contained
-
stream
Description copied from interface:TripleStore
Returns aStream
of all triples in the graph. Note:BaseStream.parallel()
is supported.- Specified by:
stream
in interfaceTripleStore
- Returns:
- a stream of triples in this graph.
-
stream
Description copied from interface:TripleStore
Returns aStream
of Triples matching the given pattern. Note:BaseStream.parallel()
is supported.- Specified by:
stream
in interfaceTripleStore
- Parameters:
tripleMatch
- triple match pattern- Returns:
- a stream of triples in this graph matching the pattern.
-
find
Description copied from interface:TripleStore
Returns anExtendedIterator
of all triples in the graph matching the given triple match.- Specified by:
find
in interfaceTripleStore
-
copy
Description copied from interface:TripleStore
Return a new triple store that is a copy of this one. Since Nodes and Triples are immutable and shared, the copy can share the same Nodes and Triples.- Specified by:
copy
in interfaceorg.apache.jena.atlas.lib.Copyable<TripleStore>
- Specified by:
copy
in interfaceTripleStore
- Returns:
- an independent copy of this store
-