Uses of Class
com.bigdata.btree.keys.KVO

Packages that use KVO

Package	Description
com.bigdata.btree.keys
com.bigdata.btree.proc
com.bigdata.rdf.lexicon
com.bigdata.service.ndx
com.bigdata.service.ndx.pipeline

Uses of KVO in com.bigdata.btree.keys

Subclasses of KVO in com.bigdata.btree.keys

Modifier and Type	Class and Description
class	KV A key-value pair.

Methods in com.bigdata.btree.keys that return KVO

Modifier and Type	Method and Description
static <T> KVO<T>[]	KVO.dense(KVO<T>[] a, int len) Return a dense array.

Methods in com.bigdata.btree.keys with parameters of type KVO

Modifier and Type	Method and Description
int	KVO.compareTo(KVO<O> arg0) Imposes an unsigned byte[] order on the KVOs.
static <T> KVO<T>[]	KVO.dense(KVO<T>[] a, int len) Return a dense array.
static byte[][]	KVO.getKeys(KVO<?>[] chunk) Return a dense array of the keys in a KVO[] chunk.
static byte[][]	KVO.getVals(KVO<?>[] chunk) Return a dense array of the values in a KVO[] chunk.

Uses of KVO in com.bigdata.btree.proc

Classes in com.bigdata.btree.proc with type parameters of type KVO

Modifier and Type	Interface and Description
interface	IAsyncResultHandler<R,A,O,X extends KVO<O>> Interface for chunk-at-a-time result processing for asynchronous index writes.

Methods in com.bigdata.btree.proc with parameters of type KVO

Modifier and Type	Method and Description
void	IAsyncResultHandler.aggregateAsync(X[] chunk, R result, Split split) Method is invoked for each result and is responsible for combining the results in whatever manner is meaningful for the procedure.

Uses of KVO in com.bigdata.rdf.lexicon

Fields in com.bigdata.rdf.lexicon with type parameters of type KVO

Modifier and Type	Field and Description
static Comparator<KVO<BigdataValue>>	KVOTermIdComparator.INSTANCE

Methods in com.bigdata.rdf.lexicon that return KVO

Modifier and Type	Method and Description
KVO<BigdataValue>[]	BlobsWriteTask.call() Unify the BigdataValues with the TERMS index, setting the IVs on the BigdataValues as a side-effect.
KVO<BigdataValue>[]	Term2IdWriteTask.call() Unify the BigdataValues with the TERM2ID index, setting the term identifiers (TIDs) on those values as a side-effect.
KVO<BigdataValue>[]	BlobsIndexHelper.generateKVOs(BigdataValueSerializer<BigdataValue> valSer, BigdataValue[] terms, int numTerms) Generate the sort keys for BigdataValues to be represented as BlobIVs.

Methods in com.bigdata.rdf.lexicon with parameters of type KVO

Modifier and Type	Method and Description
void	AssignTermId.apply(KVO<BigdataValue> t)
int	KVOTermIdComparator.compare(KVO<BigdataValue> term1, KVO<BigdataValue> term2) Note: defers to natural ordering for IV objects.
int	KVOTermIdComparator.compare(KVO<BigdataValue> term1, KVO<BigdataValue> term2) Note: defers to natural ordering for IV objects.

Constructors in com.bigdata.rdf.lexicon with parameters of type KVO

Constructor and Description
ReverseIndexWriterTask(IIndex idTermIndex, BigdataValueFactory valueFactory, KVO<BigdataValue>[] a, int ndistinct, boolean storeBlankNodes)

Uses of KVO in com.bigdata.service.ndx

Methods in com.bigdata.service.ndx with parameters of type KVO

Modifier and Type	Method and Description
LinkedList<Split>	AbstractSplitter.splitKeys(long ts, int fromIndex, int toIndex, KVO[] a) Reshape the data into an unsigned byte[][] and then invoke AbstractSplitter.splitKeys(long, int, int, byte[][]).
LinkedList<Split>	ISplitter.splitKeys(long ts, int fromIndex, int toIndex, KVO[] a) Identify the Splits for an ordered KVO[] such that there is one Split per index partition spanned by the data.
LinkedList<Split>	AbstractScaleOutClientIndexView.splitKeys(long ts, int fromIndex, int toIndex, KVO[] a)
LinkedList<Split>	ClientIndexView.splitKeys(long ts, int fromIndex, int toIndex, KVO[] a)

Uses of KVO in com.bigdata.service.ndx.pipeline

Classes in com.bigdata.service.ndx.pipeline with type parameters of type KVO

Modifier and Type	Class and Description
class	IndexPartitionWriteTask<H extends IndexAsyncWriteStats<L,HS>,O,E extends KVO<O>,L extends PartitionLocator,S extends IndexPartitionWriteTask,HS extends IndexPartitionWriteStats,M extends IndexWriteTask<H,O,E,S,L,HS,T,R,A>,T extends IKeyArrayIndexProcedure,R,A> Class drains a BlockingBuffer writing on a specific index partition.
class	IndexWriteTask<H extends IndexAsyncWriteStats<L,HS>,O,E extends KVO<O>,S extends IndexPartitionWriteTask,L extends PartitionLocator,HS extends IndexPartitionWriteStats,T extends IKeyArrayIndexProcedure,R,A> Task drains a BlockingBuffer containing KVO[] chunks, splits the chunks based on the separator keys for the scale-out index, and then assigns each chunk to per-index partition BlockingBuffer which is in turned drained by an IndexPartitionWriteTask that writes onto a specific index partition.
class	MockMaster<H extends MockMasterStats<L,HS>,O,E extends KVO<O>,S extends MockSubtask,L,HS extends MockSubtaskStats> Class exists solely to make it easier to write the unit tests by aligning the various generic types across the master, the subtask, and their statistics objects.
class	MockSubtask<H extends MockMasterStats<L,HS>,O,E extends KVO<O>,L,S extends MockSubtask,HS extends MockSubtaskStats,M extends MockMaster<H,O,E,S,L,HS>> Class exists solely to make it easier to write the unit tests by aligning the various generic types across the master, the subtask, and their statistics objects.

Subclasses of KVO in com.bigdata.service.ndx.pipeline

Modifier and Type	Class and Description
class	KVOC<O> Extends KVOList to provide handshaking with a KVOLatch.
class	KVOList<O> Extends KVO to allow duplicates to be gathered together in a doubly-linked list.

Methods in com.bigdata.service.ndx.pipeline that return KVO

Modifier and Type	Method and Description
KVO<O>[]	IDuplicateRemover.filter(KVO<O>[] a) Accepts a dense array of key-value tuples and returns a dense array of key-value tuples in which duplicates have been eliminated.
KVO<O>[]	NOPDuplicateRemover.filter(KVO<O>[] a) Returns its argument.
KVO<O>[]	DefaultDuplicateRemover.filter(KVO<O>[] src)

Methods in com.bigdata.service.ndx.pipeline with parameters of type KVO

Modifier and Type	Method and Description
void	KVOList.add(KVO<O> o) Add a reference to the duplicates list.
void	KVOList.Op.apply(KVO<O> o)
KVO<O>[]	IDuplicateRemover.filter(KVO<O>[] a) Accepts a dense array of key-value tuples and returns a dense array of key-value tuples in which duplicates have been eliminated.
KVO<O>[]	NOPDuplicateRemover.filter(KVO<O>[] a) Returns its argument.
KVO<O>[]	DefaultDuplicateRemover.filter(KVO<O>[] src)
protected boolean	DefaultDuplicateRemover.filterDuplicate(KVO<O> prior, KVO<O> other) Return true if the other instance is a duplicate and may be dropped.
protected boolean	DefaultDuplicateRemover.filterDuplicate(KVO<O> prior, KVO<O> other) Return true if the other instance is a duplicate and may be dropped.
protected boolean	IndexPartitionWriteTask.handleChunk(E[] sourceChunk) Process a chunk from the buffer.
protected void	IndexWriteTask.handleChunk(E[] a, boolean reopen) Splits the chunk according to the current index partitions and transfers each split to the appropriate sink.