edu.iu.harp.partition

Class Partition<P extends Simple>

java.lang.Object

edu.iu.harp.resource.Transferable

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

public final class Partition<P extends Simple>
extends Transferable

Partition provides a wrapper on an array or an object. Partitions have partition IDs which is used to identify themselves in the distributed dataset.

Constructor Summary

Constructors

Constructor and Description
Partition(int partitionID, P partition)

Method Summary

Modifier and Type	Method and Description
void	encode(java.io.DataOutput out) Encode the partition data as DataOutput
void	free() Free and reset the partition
P	get() Get the partition body
int	getNumEnocdeBytes() Get the number bytes of encoded data.
int	id() Get the partition ID
void	release() Release and reset the partition

Methods inherited from class java.lang.Object

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

Constructor Detail

Partition

public Partition(int partitionID,
                 P partition)

Method Detail

id

public int id()

Get the partition ID

Returns:

ID

get

public P get()

Get the partition body

Returns:

partition body

getNumEnocdeBytes

public int getNumEnocdeBytes()

Get the number bytes of encoded data. Four for storing the partitionID, plus the number bytes of encoded partition body data

Specified by:

getNumEnocdeBytes in class Transferable

Returns:

number of bytes

encode

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

Encode the partition data as DataOutput

Specified by:

encode in class Transferable

Throws:

java.io.IOException

release

public void release()

Release and reset the partition

Specified by:

release in class Transferable

free

public void free()

Free and reset the partition

Specified by:

free in class Transferable