Package be.bagofwords.db
Interface DataInterface<T>
-
- All Superinterfaces:
be.bagofwords.iterator.DataIterable<be.bagofwords.util.KeyValue<T>>,Iterable<be.bagofwords.util.KeyValue<T>>
- All Known Implementing Classes:
BaseDataInterface,BloomFilterDataInterface,CachedDataInterface,CoreDataInterface,FileDataInterface,InMemoryDataInterface,LayeredDataInterface,RemoteDataInterface
public interface DataInterface<T> extends be.bagofwords.iterator.DataIterable<be.bagofwords.util.KeyValue<T>>Created by koen on 19/05/17.
-
-
Method Summary
All Methods Instance Methods Abstract Methods Default Methods Modifier and Type Method Description longapprDataChecksum()longapprSize()default be.bagofwords.iterator.CloseableIterator<be.bagofwords.util.KeyValue<T>>cachedValueIterator()voidclose()voiddropAllData()longexactSize()voidflush()Combinator<T>getCombinator()DataInterface<T>getCoreDataInterface()StringgetName()Class<T>getObjectClass()ObjectSerializer<T>getObjectSerializer()voidifNotClosed(Runnable action)default voidincreaseCount(long key)default voidincreaseCount(long key, Long value)default voidincreaseCount(String key)default voidincreaseCount(String key, Long value)booleanisTemporaryDataInterface()be.bagofwords.iterator.CloseableIterator<be.bagofwords.util.KeyValue<T>>iterator()default be.bagofwords.iterator.CloseableIterator<be.bagofwords.util.KeyValue<T>>iterator(KeyFilter keyFilter)default be.bagofwords.iterator.CloseableIterator<be.bagofwords.util.KeyValue<T>>iterator(be.bagofwords.iterator.CloseableIterator<Long> keyIterator)default be.bagofwords.iterator.CloseableIterator<be.bagofwords.util.KeyValue<T>>iterator(java.util.function.Predicate<T> valueFilter)default be.bagofwords.iterator.CloseableIterator<be.bagofwords.util.KeyValue<T>>iterator(java.util.stream.Stream<Long> keyStream)default be.bagofwords.iterator.CloseableIterator<Long>keyIterator()default booleanmightContain(long key)default booleanmightContain(String key)voidoptimizeForReading()Tread(long key)default Tread(be.bagofwords.text.BowString key)default Tread(String key)default longreadCount(long key)default longreadCount(be.bagofwords.text.BowString key)default longreadCount(String key)voidregisterUpdateListener(UpdateListener<T> updateListener)default voidremove(long key)default voidremove(String key)default java.util.stream.Stream<be.bagofwords.util.KeyValue<T>>stream()default java.util.stream.Stream<be.bagofwords.util.KeyValue<T>>stream(KeyFilter keyFilter)default java.util.stream.Stream<be.bagofwords.util.KeyValue<T>>stream(be.bagofwords.iterator.CloseableIterator<Long> keyIterator)default java.util.stream.Stream<be.bagofwords.util.KeyValue<T>>stream(java.util.function.Predicate<T> valueFilter)default java.util.stream.Stream<Long>streamKeys()default java.util.stream.Stream<T>streamValues()default java.util.stream.Stream<T>streamValues(KeyFilter keyFilter)default java.util.stream.Stream<T>streamValues(be.bagofwords.iterator.CloseableIterator<Long> keyIterator)default java.util.stream.Stream<T>streamValues(java.util.function.Predicate<T> valueFilter)default java.util.stream.Stream<T>streamValues(java.util.stream.Stream<Long> keysStream)default be.bagofwords.iterator.CloseableIterator<T>valueIterator()default be.bagofwords.iterator.CloseableIterator<T>valueIterator(KeyFilter keyFilter)default be.bagofwords.iterator.CloseableIterator<T>valueIterator(be.bagofwords.iterator.CloseableIterator<Long> keyIterator)default be.bagofwords.iterator.CloseableIterator<T>valueIterator(java.util.function.Predicate<T> valueFilter)default be.bagofwords.iterator.CloseableIterator<T>valueIterator(java.util.stream.Stream<Long> keyStream)booleanwasClosed()voidwrite(long key, T value)default voidwrite(be.bagofwords.iterator.CloseableIterator<be.bagofwords.util.KeyValue<T>> entries)default voidwrite(be.bagofwords.text.BowString key, T value)default voidwrite(String key, T value)default voidwrite(Iterator<be.bagofwords.util.KeyValue<T>> entries)-
Methods inherited from interface java.lang.Iterable
forEach, spliterator
-
-
-
-
Method Detail
-
read
T read(long key)
-
readCount
default long readCount(long key)
-
read
default T read(be.bagofwords.text.BowString key)
-
readCount
default long readCount(be.bagofwords.text.BowString key)
-
readCount
default long readCount(String key)
-
mightContain
default boolean mightContain(String key)
-
mightContain
default boolean mightContain(long key)
-
keyIterator
default be.bagofwords.iterator.CloseableIterator<Long> keyIterator()
-
valueIterator
default be.bagofwords.iterator.CloseableIterator<T> valueIterator()
-
valueIterator
default be.bagofwords.iterator.CloseableIterator<T> valueIterator(KeyFilter keyFilter)
-
valueIterator
default be.bagofwords.iterator.CloseableIterator<T> valueIterator(java.util.function.Predicate<T> valueFilter)
-
valueIterator
default be.bagofwords.iterator.CloseableIterator<T> valueIterator(be.bagofwords.iterator.CloseableIterator<Long> keyIterator)
-
valueIterator
default be.bagofwords.iterator.CloseableIterator<T> valueIterator(java.util.stream.Stream<Long> keyStream)
-
iterator
default be.bagofwords.iterator.CloseableIterator<be.bagofwords.util.KeyValue<T>> iterator(KeyFilter keyFilter)
-
iterator
default be.bagofwords.iterator.CloseableIterator<be.bagofwords.util.KeyValue<T>> iterator(java.util.function.Predicate<T> valueFilter)
-
iterator
default be.bagofwords.iterator.CloseableIterator<be.bagofwords.util.KeyValue<T>> iterator(java.util.stream.Stream<Long> keyStream)
-
iterator
default be.bagofwords.iterator.CloseableIterator<be.bagofwords.util.KeyValue<T>> iterator(be.bagofwords.iterator.CloseableIterator<Long> keyIterator)
-
cachedValueIterator
default be.bagofwords.iterator.CloseableIterator<be.bagofwords.util.KeyValue<T>> cachedValueIterator()
-
iterator
be.bagofwords.iterator.CloseableIterator<be.bagofwords.util.KeyValue<T>> iterator()
-
apprSize
long apprSize()
- Specified by:
apprSizein interfacebe.bagofwords.iterator.DataIterable<T>
-
apprDataChecksum
long apprDataChecksum()
-
exactSize
long exactSize()
-
stream
default java.util.stream.Stream<be.bagofwords.util.KeyValue<T>> stream()
-
stream
default java.util.stream.Stream<be.bagofwords.util.KeyValue<T>> stream(java.util.function.Predicate<T> valueFilter)
-
stream
default java.util.stream.Stream<be.bagofwords.util.KeyValue<T>> stream(be.bagofwords.iterator.CloseableIterator<Long> keyIterator)
-
streamValues
default java.util.stream.Stream<T> streamValues()
-
streamValues
default java.util.stream.Stream<T> streamValues(java.util.function.Predicate<T> valueFilter)
-
streamValues
default java.util.stream.Stream<T> streamValues(be.bagofwords.iterator.CloseableIterator<Long> keyIterator)
-
streamValues
default java.util.stream.Stream<T> streamValues(java.util.stream.Stream<Long> keysStream)
-
streamKeys
default java.util.stream.Stream<Long> streamKeys()
-
getName
String getName()
-
optimizeForReading
void optimizeForReading()
-
write
void write(long key, T value)
-
write
default void write(be.bagofwords.iterator.CloseableIterator<be.bagofwords.util.KeyValue<T>> entries)
-
write
default void write(be.bagofwords.text.BowString key, T value)
-
increaseCount
default void increaseCount(long key, Long value)
-
increaseCount
default void increaseCount(String key)
-
increaseCount
default void increaseCount(long key)
-
remove
default void remove(String key)
-
remove
default void remove(long key)
-
getCombinator
Combinator<T> getCombinator()
-
close
void close()
-
wasClosed
boolean wasClosed()
-
isTemporaryDataInterface
boolean isTemporaryDataInterface()
-
flush
void flush()
-
dropAllData
void dropAllData()
-
ifNotClosed
void ifNotClosed(Runnable action)
-
getCoreDataInterface
DataInterface<T> getCoreDataInterface()
-
getObjectSerializer
ObjectSerializer<T> getObjectSerializer()
-
registerUpdateListener
void registerUpdateListener(UpdateListener<T> updateListener)
-
-