edu.iu.harp.keyval

Class Int2ValKVTable<V extends Value,P extends Int2ValKVPartition<V>>

java.lang.Object

edu.iu.harp.partition.Table<P>

edu.iu.harp.keyval.KVTable<P>

edu.iu.harp.keyval.Int2ValKVTable<V,P>

Direct Known Subclasses:

EdgeTable, MessageTable, VertexTable

public abstract class Int2ValKVTable<V extends Value,P extends Int2ValKVPartition<V>>
extends KVTable<P>

A KVTable manages Int2ValKVPartitions

Constructor Summary

Constructors

Constructor and Description
Int2ValKVTable(int tableID, ValCombiner<V> combiner, java.lang.Class<V> vClass, java.lang.Class<P> pClass)

Method Summary

Modifier and Type	Method and Description
ValStatus	addKeyVal(int key, V val) Add a new key-value pair to the table.
protected int	getKVPartitionID(int key) Get the partition Id by key
V	getVal(int key) Get the value associated with the key
V	removeVal(int key) Remove the value associated with the key

Methods inherited from class edu.iu.harp.partition.Table

addPartition, free, getCombiner, getNumPartitions, getPartition, getPartitionIDs, getPartitions, getTableID, insertPartition, isEmpty, release, removePartition

Methods inherited from class java.lang.Object

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

Constructor Detail

Int2ValKVTable

public Int2ValKVTable(int tableID,
                      ValCombiner<V> combiner,
                      java.lang.Class<V> vClass,
                      java.lang.Class<P> pClass)

Method Detail

addKeyVal

public ValStatus addKeyVal(int key,
                           V val)

Add a new key-value pair to the table. If the key exists, combine the old one and the new one, else, create a new partition and then add the new key-value pair to it.

Parameters:

key - the key

val - the value

getVal

public V getVal(int key)

Get the value associated with the key

Parameters:

key - the key

Returns:

the value

removeVal

public V removeVal(int key)

Remove the value associated with the key

Parameters:

key - the key

Returns:

the value, or null if not exists

getKVPartitionID

protected int getKVPartitionID(int key)

Get the partition Id by key

Parameters:

key - the key

Returns:

the partition id