edu.iu.harp.keyval

Class Key2ValKVTable<K extends Key,V extends Value,P extends Key2ValKVPartition<K,V>>

java.lang.Object

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

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

edu.iu.harp.keyval.Key2ValKVTable<K,V,P>

Direct Known Subclasses:

WordCountTable

public abstract class Key2ValKVTable<K extends Key,V extends Value,P extends Key2ValKVPartition<K,V>>
extends KVTable<P>

An abstract class of Key-Vale tables

Constructor Summary

Constructors

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

Method Summary

Modifier and Type	Method and Description
ValStatus	addKeyVal(K key, V val) Add a new key-value pair to the table.
protected int	getKVPartitionID(K key) Get the partition Id by key
V	getVal(K key) Get the value associated with the key
V	removeVal(K 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

Key2ValKVTable

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

Method Detail

addKeyVal

public ValStatus addKeyVal(K 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

Returns:

the ValStatus

getVal

public V getVal(K key)

Get the value associated with the key

Parameters:

key - the key

Returns:

the value, or null if not exists

removeVal

public V removeVal(K key)

Remove the value associated with the key

Parameters:

key - the key

Returns:

the value, or null if not exists

getKVPartitionID

protected int getKVPartitionID(K key)

Get the partition Id by key

Parameters:

key - the key

Returns:

the partition id