Package org.eclipse.rdf4j.collection.factory.mapdb

Class MapDbCollectionFactory

java.lang.Object

org.eclipse.rdf4j.collection.factory.mapdb.MapDbCollectionFactory

All Implemented Interfaces:

AutoCloseable, CollectionFactory

public class MapDbCollectionFactory
extends Object
implements CollectionFactory

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
protected static final class	MapDbCollectionFactory.CommitingMap<K,V>
protected static final class	MapDbCollectionFactory.CommitingSet<T>
protected class	MapDbCollectionFactory.MemoryTillSizeXSet<V>	Only create a disk based set once the contents are large enough that it starts to pay off.

Field Summary

Fields

Modifier and Type	Field	Description
protected long	colectionId
protected org.mapdb.DB	db
protected final long	iterationCacheSyncThreshold

Constructor Summary

Constructors

Constructor	Description
MapDbCollectionFactory(long iterationCacheSyncThreshold)
MapDbCollectionFactory(long iterationCacheSyncThreshold, CollectionFactory delegate)

Method Summary

Modifier and Type	Method	Description
void	close()
BindingSetKey	createBindingSetKey(BindingSet bindingSet, List<Function<BindingSet,Value>> getValues, ToIntFunction<BindingSet> hashOfBindingSetCalculator)
<E> Map<BindingSetKey,E>	createGroupByMap()
<T> List<T>	createList()
<K, V> Map<K,V>	createMap()
<T> Queue<T>	createQueue()
<T> Set<T>	createSet()
Set<BindingSet>	createSetOfBindingSets()
Set<BindingSet>	createSetOfBindingSets(Supplier<MutableBindingSet> create, Function<String,Predicate<BindingSet>> getHas, Function<String,Function<BindingSet,Value>> getget, Function<String,BiConsumer<Value,MutableBindingSet>> getSet)	Allows optimizations beyond what would otherwise be possible, regarding disk access and storage.
<V> Map<Value,V>	createValueKeyedMap()
List<Value>	createValueList()
Queue<Value>	createValueQueue()
Set<Value>	createValueSet()
protected void	init()

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Methods inherited from interface org.eclipse.rdf4j.collection.factory.api.CollectionFactory

createBindingSetQueue, createBindingSetQueue, hashAValue, hashOfBindingSetFuntion

Field Details

db

protected volatile org.mapdb.DB db

colectionId

protected volatile long colectionId

iterationCacheSyncThreshold

protected final long iterationCacheSyncThreshold

Constructor Details

MapDbCollectionFactory

public MapDbCollectionFactory(long iterationCacheSyncThreshold)

MapDbCollectionFactory

public MapDbCollectionFactory(long iterationCacheSyncThreshold,
 CollectionFactory delegate)

Method Details

init

protected void init()

createList

public <T> List<T> createList()

Specified by:

createList in interface CollectionFactory

Type Parameters:

T - of the list

Returns:

a list that may be optimised and/or disk based

createValueList

public List<Value> createValueList()

Specified by:

createValueList in interface CollectionFactory

Returns:

a list that may be optimised and/or disk based for Values only

createSetOfBindingSets

public Set<BindingSet> createSetOfBindingSets(Supplier<MutableBindingSet> create,
 Function<String,Predicate<BindingSet>> getHas,
 Function<String,Function<BindingSet,Value>> getget,
 Function<String,BiConsumer<Value,MutableBindingSet>> getSet)

Description copied from interface: CollectionFactory

Allows optimizations beyond what would otherwise be possible, regarding disk access and storage.

Specified by:

createSetOfBindingSets in interface CollectionFactory

Parameters:

create - a supplier that makes bindingsets

Returns:

a set that may be optimised and/or disk based

createSetOfBindingSets

public Set<BindingSet> createSetOfBindingSets()

Specified by:

createSetOfBindingSets in interface CollectionFactory

Returns:

a set that may be optimised and/or disk based

createSet

public <T> Set<T> createSet()

Specified by:

createSet in interface CollectionFactory

Type Parameters:

T - of the set

Returns:

a set that may be optimised and/or disk based

createValueSet

public Set<Value> createValueSet()

Specified by:

createValueSet in interface CollectionFactory

Returns:

a set that may be optimised and/or disk based for Values

createMap

public <K,
V> Map<K,V> createMap()

Specified by:

createMap in interface CollectionFactory

Type Parameters:

K - key type

V - value type

Returns:

a map

createValueKeyedMap

public <V> Map<Value,V> createValueKeyedMap()

Specified by:

createValueKeyedMap in interface CollectionFactory

Type Parameters:

V - value type

Returns:

a map

createQueue

public <T> Queue<T> createQueue()

Specified by:

createQueue in interface CollectionFactory

Type Parameters:

T - of the contents of the queue

Returns:

a new queue

createValueQueue

public Queue<Value> createValueQueue()

Specified by:

createValueQueue in interface CollectionFactory

Returns:

a new queue

close

public void close()
           throws RDF4JException

Specified by:

close in interface AutoCloseable

Specified by:

close in interface CollectionFactory

Throws:

RDF4JException

createGroupByMap

public <E> Map<BindingSetKey,E> createGroupByMap()

Specified by:

createGroupByMap in interface CollectionFactory

createBindingSetKey

public BindingSetKey createBindingSetKey(BindingSet bindingSet,
 List<Function<BindingSet,Value>> getValues,
 ToIntFunction<BindingSet> hashOfBindingSetCalculator)

Specified by:

createBindingSetKey in interface CollectionFactory