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

Class MapDb3CollectionFactory

java.lang.Object

org.eclipse.rdf4j.collection.factory.mapdb.MapDb3CollectionFactory

All Implemented Interfaces:

AutoCloseable, CollectionFactory

public class MapDb3CollectionFactory
extends Object
implements CollectionFactory

Nested Class Summary

Nested Classes

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

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
MapDb3CollectionFactory(long iterationCacheSyncThreshold)
MapDb3CollectionFactory(long iterationCacheSyncThreshold, CollectionFactory delegate)

Method Summary

Modifier and Type	Method	Description
void	close()
protected <T> org.mapdb.Serializer<T>	createAnySerializer()
final BindingSetKey	createBindingSetKey(BindingSet bindingSet, List<Function<BindingSet,Value>> getValues, ToIntFunction<BindingSet> hashOfBindingSetCalculator)
protected final org.mapdb.Serializer<BindingSetKey>	createBindingSetKeySerializer()
Queue<BindingSet>	createBindingSetQueue(Supplier<MutableBindingSet> create, Function<String,Predicate<BindingSet>> getHas, Function<String,Function<BindingSet,Value>> getget, Function<String,BiConsumer<Value,MutableBindingSet>> getSet)
protected org.mapdb.Serializer<BindingSet>	createBindingSetSerializer(Supplier<MutableBindingSet> create, Function<String,Predicate<BindingSet>> getHas, Function<String,Function<BindingSet,Value>> getGet, Function<String,BiConsumer<Value,MutableBindingSet>> getSet)	These methods should be overriding in case a store can deliver a better serialization protocol.
<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(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()
protected org.mapdb.Serializer<Value>	createValueSerializer()
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, createSetOfBindingSets, hashAValue, hashOfBindingSetFuntion

Field Details

db

protected volatile org.mapdb.DB db

colectionId

protected volatile long colectionId

iterationCacheSyncThreshold

protected final long iterationCacheSyncThreshold

Constructor Details

MapDb3CollectionFactory

public MapDb3CollectionFactory(long iterationCacheSyncThreshold)

MapDb3CollectionFactory

public MapDb3CollectionFactory(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

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

createBindingSetQueue

@Experimental
public Queue<BindingSet> createBindingSetQueue(Supplier<MutableBindingSet> create,
 Function<String,Predicate<BindingSet>> getHas,
 Function<String,Function<BindingSet,Value>> getget,
 Function<String,BiConsumer<Value,MutableBindingSet>> getSet)

Specified by:

createBindingSetQueue in interface CollectionFactory

Returns:

a new queue that may be optimized and may use the functions passed in.

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 final BindingSetKey createBindingSetKey(BindingSet bindingSet,
 List<Function<BindingSet,Value>> getValues,
 ToIntFunction<BindingSet> hashOfBindingSetCalculator)

Specified by:

createBindingSetKey in interface CollectionFactory

createBindingSetSerializer

protected org.mapdb.Serializer<BindingSet> createBindingSetSerializer(Supplier<MutableBindingSet> create,
 Function<String,Predicate<BindingSet>> getHas,
 Function<String,Function<BindingSet,Value>> getGet,
 Function<String,BiConsumer<Value,MutableBindingSet>> getSet)

These methods should be overriding in case a store can deliver a better serialization protocol.

Parameters:

create -

getHas -

getGet -

createAnySerializer

protected <T> org.mapdb.Serializer<T> createAnySerializer()

createValueSerializer

protected org.mapdb.Serializer<Value> createValueSerializer()

createBindingSetKeySerializer

protected final org.mapdb.Serializer<BindingSetKey> createBindingSetKeySerializer()