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

Packages that use KVO

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

class

KV A key-value pair.

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

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

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

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

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

static Comparator<KVO<BigdataValue>>

KVOTermIdComparator.INSTANCE

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

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>[]	BlobsWriteTask.call() Unify the BigdataValues with the TERMS index, setting the IVs on the BigdataValues 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

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

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

LinkedList<Split>	ClientIndexView.splitKeys(long ts, int fromIndex, int toIndex, KVO[] a)
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>	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[][]).

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

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

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.

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

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

KVO<O>[]	NOPDuplicateRemover.filter(KVO<O>[] a) Returns its argument.
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>[]	DefaultDuplicateRemover.filter(KVO<O>[] src)

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

void	KVOList.add(KVO<O> o) Add a reference to the duplicates list.
void	KVOList.Op.apply(KVO<O> o)
KVO<O>[]	NOPDuplicateRemover.filter(KVO<O>[] a) Returns its argument.
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>[]	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.