edu.iu.harp.util

Class Join

java.lang.Object

edu.iu.harp.resource.Transferable

edu.iu.harp.resource.Simple

edu.iu.harp.resource.Writable

edu.iu.harp.util.Join

public class Join
extends Writable

This class records the destinations of each partition. Each partition could have multi-destinations.

Constructor Summary

Constructors

Constructor and Description
Join()

Method Summary

Modifier and Type	Method and Description
void	clear() Clear the data
int	getNumWriteBytes() Get the number of bytes of encoded data
<any>	getParToWorkerMap() Get the parToWorkerMap
Int2IntOpenHashMap	getWorkerParCountMap() Get the workerParCountMap
void	read(java.io.DataInput in) Read this from DataInput
void	setParToWorkerMap(<any> partitionToWorkerMap) Set the parToWorkerMap
void	setWorkerParCountMap(Int2IntOpenHashMap workerPartitionCountMap) Set the workerPartitionCountMap
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

Join

public Join()

Method Detail

setParToWorkerMap

public void setParToWorkerMap(<any> partitionToWorkerMap)

Set the parToWorkerMap

Parameters:

partitionToWorkerMap - the parToWorkerMap

getParToWorkerMap

public <any> getParToWorkerMap()

Get the parToWorkerMap

Returns:

the parToWorkerMap

setWorkerParCountMap

public void setWorkerParCountMap(Int2IntOpenHashMap workerPartitionCountMap)

Set the workerPartitionCountMap

Parameters:

workerPartitionCountMap - the workerPartitionCountMap

getWorkerParCountMap

public Int2IntOpenHashMap getWorkerParCountMap()

Get the workerParCountMap

Returns:

the workerParCountMap

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

clear

public void clear()

Clear the data

Specified by:

clear in class Writable