edu.iu.harp.util

Class PartitionSet

java.lang.Object

edu.iu.harp.resource.Transferable

edu.iu.harp.resource.Simple

edu.iu.harp.resource.Writable

edu.iu.harp.util.PartitionSet

public class PartitionSet
extends Writable

PartitionSet is the set of partition IDs on the worker

Constructor Summary

Constructors

Constructor and Description
PartitionSet()

Method Summary

Modifier and Type	Method and Description
void	clear() Clear the parIDs
int	getNumWriteBytes() Get the number of bytes of encoded data 4 for storing worker ID, 4 for storing the size of parIDs, the rest for storing the parIDs
IntArrayList	getParSet() Get the partition ID set
int	getWorkerID() Get the worker ID
void	read(java.io.DataInput in) Read PartitionSet from DataInput
void	setParSet(IntArrayList partitionSet) Set the partition ID set
void	setWorkerID(int id) Set the worker ID
void	write(java.io.DataOutput out) Write the PartitionSet 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

PartitionSet

public PartitionSet()

Method Detail

setWorkerID

public void setWorkerID(int id)

Set the worker ID

Parameters:

id - woker ID to set

getWorkerID

public int getWorkerID()

Get the worker ID

Returns:

worker ID

setParSet

public void setParSet(IntArrayList partitionSet)

Set the partition ID set

Parameters:

partitionSet - partition ID set

getParSet

public IntArrayList getParSet()

Get the partition ID set

Returns:

partition ID set

getNumWriteBytes

public int getNumWriteBytes()

Get the number of bytes of encoded data 4 for storing worker ID, 4 for storing the size of parIDs, the rest for storing the parIDs

Specified by:

getNumWriteBytes in class Writable

Returns:

number of Bytes

write

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

Write the PartitionSet 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 PartitionSet from DataInput

Specified by:

read in class Writable

Throws:

java.io.IOException

clear

public void clear()

Clear the parIDs

Specified by:

clear in class Writable