com.bigdata.service.ndx.pipeline

Class KVOList<O>

java.lang.Object

com.bigdata.btree.keys.KVO<O>

com.bigdata.service.ndx.pipeline.KVOList<O>

Type Parameters:

O - The generic type of the unserialized value object.

All Implemented Interfaces:

Comparable<KVO<O>>

Direct Known Subclasses:

KVOC

public class KVOList<O>
extends KVO<O>

Extends KVO to allow duplicates to be gathered together in a doubly-linked list. This is used to facilitate duplicate removal where the goal is to eliminate the index write for the duplicate instance(s) but where we still want to take some after action for each distinct instance.

Version:

$Id$

Author:

Bryan Thompson

See Also:

IDuplicateRemover

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static interface	KVOList.Op<O> An operation which can be mapped over the duplicate list.

Field Summary

Fields inherited from class com.bigdata.btree.keys.KVO

key, obj, val

Constructor Summary

Constructors

Constructor and Description
KVOList(byte[] key, byte[] val, O obj)

Method Summary

Methods

Modifier and Type	Method and Description
void	add(KVO<O> o) Add a reference to the duplicates list.
void	done() Extended to map the operation over the duplicate list.
int	getDuplicateCount() The #of duplicates on the internal list.
boolean	isDuplicateListEmpty() Return true iff no duplicates have been assigned.
void	map(KVOList.Op<O> op) Maps the operation across the duplicate list (the operation is NOT applied to the original).

Methods inherited from class com.bigdata.btree.keys.KVO

compareTo, dense, getKeys, getVals, toString

Methods inherited from class java.lang.Object

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

Constructor Detail

KVOList

public KVOList(byte[] key,
       byte[] val,
       O obj)

Parameters:

key - The unsigned byte[] key (required).

val - The byte[] value (optional).

obj - The paired application object (optional).

latch - The object that maintains the counter.

Method Detail

add

public void add(KVO<O> o)

Add a reference to the duplicates list. This is MUTEX with done().

Parameters:

o - A duplicate of this object.

getDuplicateCount

public int getDuplicateCount()

The #of duplicates on the internal list. This will report ZERO (0) if there are no duplicates (the internal list is empty).

isDuplicateListEmpty

public boolean isDuplicateListEmpty()

Return true iff no duplicates have been assigned.

done

public void done()

Extended to map the operation over the duplicate list.

Overrides:

done in class KVO<O>

map

public void map(KVOList.Op<O> op)

Maps the operation across the duplicate list (the operation is NOT applied to the original).

Parameters:

op - The operation.