com.bigdata.service.ndx.pipeline

Class KVOC<O>

java.lang.Object

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

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

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

Type Parameters:

O - The generic type of the unserialized value object.

All Implemented Interfaces:

Comparable<KVO<O>>

public class KVOC<O>
extends KVOList<O>

Extends KVOList to provide handshaking with a KVOLatch.

Note: IDuplicateRemovers MUST create a list from the identified duplicates so that the KVOLatch of each duplicate as well as the original are decremented after a successful write. Failure to do this will cause a Latch.dec() to be "lost" and generally results in non-termination of Latch.await() since the count for the "lost" latch would never reach zero.

Version:

$Id$

Author:

Bryan Thompson

Nested Class Summary

Nested classes/interfaces inherited from class com.bigdata.service.ndx.pipeline.KVOList

KVOList.Op<O>

Field Summary

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

key, obj, val

Constructor Summary

Constructors

Constructor and Description
KVOC(byte[] key, byte[] val, O obj, KVOLatch latch)

Method Summary

Methods

Modifier and Type	Method and Description
void	done() Extended to decrement the KVOLatch.

Methods inherited from class com.bigdata.service.ndx.pipeline.KVOList

add, getDuplicateCount, isDuplicateListEmpty, map

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

KVOC

public KVOC(byte[] key,
    byte[] val,
    O obj,
    KVOLatch latch)

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

done

public void done()

Extended to decrement the KVOLatch. This inherits from KVOList, which maps KVOList.done() over the list of duplicates. This ensures that all latches are decremented once the original value has been successfully written onto an index partition.

Overrides:

done in class KVOList<O>