Package be.bagofwords.db.experimental.index

Class MultiDataInterfaceIndex<T>

java.lang.Object

be.bagofwords.db.experimental.index.BaseDataInterfaceIndex<T>

be.bagofwords.db.experimental.index.MultiDataInterfaceIndex<T>

All Implemented Interfaces:

UpdateListener<T>

public class MultiDataInterfaceIndex<T>
extends BaseDataInterfaceIndex<T>

Field Summary

Fields inherited from class be.bagofwords.db.experimental.index.BaseDataInterfaceIndex

dataInterface

Constructor Summary

Constructors

Constructor	Description
MultiDataInterfaceIndex(String name, DataInterfaceFactory dataInterfaceFactory, DataInterface<T> dataInterface, MultiDataIndexer<T> indexer)

Method Summary

Modifier and Type	Method	Description
void	close()
void	dataDropped()
void	dataFlushed()
void	dateUpdated(long key, T value)
void	dateUpdated(List<be.bagofwords.util.KeyValue<T>> keyValues)
protected String	getIndexName()
List<be.bagofwords.util.KeyValue<T>>	read(long indexKey)
List<be.bagofwords.util.KeyValue<T>>	read(T queryByObject)
java.util.stream.Stream<be.bagofwords.util.KeyValue<T>>	streamValues()
java.util.stream.Stream<be.bagofwords.util.KeyValue<T>>	streamValues(KeyFilter keyFilter)
java.util.stream.Stream<be.bagofwords.util.KeyValue<T>>	streamValues(T queryByObject)

Methods inherited from class java.lang.Object

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

Constructor Detail

MultiDataInterfaceIndex

public MultiDataInterfaceIndex(String name,
                               DataInterfaceFactory dataInterfaceFactory,
                               DataInterface<T> dataInterface,
                               MultiDataIndexer<T> indexer)

Method Detail

getIndexName

protected String getIndexName()

Specified by:

getIndexName in class BaseDataInterfaceIndex<T>

read

public List<be.bagofwords.util.KeyValue<T>> read(long indexKey)

read

public List<be.bagofwords.util.KeyValue<T>> read(T queryByObject)

streamValues

public java.util.stream.Stream<be.bagofwords.util.KeyValue<T>> streamValues(T queryByObject)

streamValues

public java.util.stream.Stream<be.bagofwords.util.KeyValue<T>> streamValues(KeyFilter keyFilter)

streamValues

public java.util.stream.Stream<be.bagofwords.util.KeyValue<T>> streamValues()

close

public void close()

dateUpdated

public void dateUpdated(long key,
                        T value)

dateUpdated

public void dateUpdated(List<be.bagofwords.util.KeyValue<T>> keyValues)

dataFlushed

public void dataFlushed()

dataDropped

public void dataDropped()