edu.iu.harp.keyval

Class Int2ValKVPartition<V extends Value>

java.lang.Object

edu.iu.harp.resource.Transferable

edu.iu.harp.resource.Simple

edu.iu.harp.resource.Writable

edu.iu.harp.keyval.KVPartition

edu.iu.harp.keyval.Int2ValKVPartition<V>

Direct Known Subclasses:

EdgePartition, MessagePartition, VertexPartition

public abstract class Int2ValKVPartition<V extends Value>
extends KVPartition

Int2ValKVPartition manages key-value pairs in which the key is int-type and the value is object

Constructor Summary

Constructors

Constructor and Description
Int2ValKVPartition()

Method Summary

Modifier and Type	Method and Description
void	clear() Clear the partition.
<any>	getKVMap() Get the Int2ObjectOpenHashMap
int	getNumWriteBytes() Get the number of bytes of encoded data
V	getVal(int key) Get the associated value of the key
java.lang.Class<V>	getVClass() Get the class of the values
void	initialize(java.lang.Class<V> vClass) Initialization
ValStatus	putKeyVal(int key, V val, ValCombiner<V> combiner) Put the new key-value pair to the partition.
void	read(java.io.DataInput in) Read this from DataInput
V	removeVal(int key) Removes this key and the associated value from this function if it is present.
void	write(java.io.DataOutput out) Write this to DataOutput

Methods inherited from class edu.iu.harp.resource.Writable

create, encode, forClass, free, getNumEnocdeBytes, newInstance, release

Methods inherited from class java.lang.Object

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

Constructor Detail

Int2ValKVPartition

public Int2ValKVPartition()

Method Detail

initialize

public void initialize(java.lang.Class<V> vClass)

Initialization

putKeyVal

public ValStatus putKeyVal(int key,
                           V val,
                           ValCombiner<V> combiner)

Put the new key-value pair to the partition. If the key already exists in the partition, combine the original value with the new value; else, add the new key-value pair to the partition

Parameters:

key - the new key

val - the new value

combiner - the combiner

Returns:

the ValStatus

removeVal

public V removeVal(int key)

Removes this key and the associated value from this function if it is present.

Parameters:

key - the key

Returns:

the associated value

getVal

public V getVal(int key)

Get the associated value of the key

Parameters:

key - the key

Returns:

the associated value

getKVMap

public <any> getKVMap()

Get the Int2ObjectOpenHashMap

Returns:

the Int2ObjectOpenHashMap

getVClass

public java.lang.Class<V> getVClass()

Get the class of the values

Returns:

the class of the values

clear

public void clear()

Clear the partition. All Value objects will be cached in and freeVales for later reuse

Specified by:

clear in class Writable

getNumWriteBytes

public int getNumWriteBytes()

Get the number of bytes of encoded data

Specified by:

getNumWriteBytes in class Writable

Returns:

number of Bytes

write

public void write(java.io.DataOutput out)
           throws java.io.IOException

Write this to DataOutput

Specified by:

write in class Writable

Throws:

java.io.IOException

read

public void read(java.io.DataInput in)
          throws java.io.IOException

Read this from DataInput

Specified by:

read in class Writable

Throws:

java.io.IOException