edu.iu.harp.keyval

Class Int2LongKVPartition

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

public class Int2LongKVPartition
extends KVPartition

Int2LongKVPartition manages key-value pairs in which the key is int-type and the value is long-type

Constructor Summary

Constructors

Constructor and Description
Int2LongKVPartition()

Method Summary

Modifier and Type	Method and Description
void	clear() Clear the partition.
Int2LongOpenHashMap	getKVMap() Get the Int2LongOpenHashMap
int	getNumWriteBytes() Get the number of bytes of encoded data
long	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, long val, TypeLongCombiner 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

Int2LongKVPartition

public Int2LongKVPartition()

Method Detail

initialize

public void initialize()

Initialization

putKeyVal

public ValStatus putKeyVal(int key,
                           long val,
                           TypeLongCombiner 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 long getVal(int key)

Get the associated value of the key

Parameters:

key - the key

Returns:

the associated value

getKVMap

public Int2LongOpenHashMap getKVMap()

Get the Int2LongOpenHashMap

Returns:

the Int2LongOpenHashMap

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