java.lang.Object
org.apache.jena.atlas.data.AbstractDataBag<E>
org.apache.jena.atlas.data.SortedDataBag<E>
org.apache.jena.atlas.data.DistinctDataBag<E>
org.apache.jena.atlas.data.DistinctDataNet<E>
- All Implemented Interfaces:
Iterable<E>
,DataBag<E>
,org.apache.jena.atlas.lib.Closeable
,org.apache.jena.atlas.lib.Sink<E>
This class is like
DistinctDataBag
except that you are informed if the
item you just added was known to be distinct. This will normally only work until
the first spill. After that, the system may not be able to tell for sure, and will
thus return false. When you are finished adding items, you may call
netIterator()
to get any distinct items that are in the spill files but
were not indicated as distinct previously.-
Constructor Summary
ConstructorDescriptionDistinctDataNet
(ThresholdPolicy<E> policy, SerializationFactory<E> serializerFactory, Comparator<E> comparator) -
Method Summary
Modifier and TypeMethodDescriptionboolean
Returns an iterator to all additional items that are distinct but were not reported to be so at the timenetAdd(Object)
was invoked.Methods inherited from class org.apache.jena.atlas.data.DistinctDataBag
isDistinct, isSorted, iterator
Methods inherited from class org.apache.jena.atlas.data.SortedDataBag
add, cancel, close, flush, isCancelled, isClosed
Methods inherited from class org.apache.jena.atlas.data.AbstractDataBag
isEmpty, send, size
Methods inherited from class java.lang.Object
equals, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
Methods inherited from interface java.lang.Iterable
forEach, spliterator
-
Constructor Details
-
DistinctDataNet
public DistinctDataNet(ThresholdPolicy<E> policy, SerializationFactory<E> serializerFactory, Comparator<E> comparator)
-
-
Method Details
-
netAdd
- Returns:
- true if the item added is known to be distinct.
-
netIterator
Returns an iterator to all additional items that are distinct but were not reported to be so at the timenetAdd(Object)
was invoked.If you do not exhaust the iterator, you should call
Iter.close(Iterator)
to be sure any open file handles are closed.
-