edu.iu.harp.keyval

Class Int2IntKVPartition

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.Int2IntKVPartition

public class Int2IntKVPartition
extends KVPartition

Int2IntKVPartition manages key-value pairs in which the key and the value are int-type

Constructor Summary

Constructors

Constructor and Description
Int2IntKVPartition()

Method Summary

Modifier and Type	Method and Description
void	clear() Clear the partition.
Int2IntOpenHashMap	getKVMap() Get the Int2IntOpenHashMap
int	getNumWriteBytes() Get the number of bytes of encoded data
int	getVal(int key) Get the associated value of the key
void	initialize() Initialization
boolean	isEmpty() Indicates if the partition is empty or not
ValStatus	putKeyVal(int key, int val, TypeIntCombiner combiner) Put the new key-value pair to the partition.
void	read(java.io.DataInput in) Read this from DataInput
int	size() Get the number of key-value pairs
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

Int2IntKVPartition

public Int2IntKVPartition()

Method Detail

initialize

public void initialize()

Initialization

putKeyVal

public ValStatus putKeyVal(int key,
                           int val,
                           TypeIntCombiner 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

getVal

public int getVal(int key)

Get the associated value of the key

Parameters:

key - the key

Returns:

the associated value

getKVMap

public Int2IntOpenHashMap getKVMap()

Get the Int2IntOpenHashMap

Returns:

the Int2IntOpenHashMap

size

public int size()

Get the number of key-value pairs

Returns:

the number of key-value pairs

isEmpty

public boolean isEmpty()

Indicates if the partition is empty or not

Returns:

true if empty, false if not

clear

public void clear()

Clear the partition.

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