org.apache.reef.io.network.group.impl

Class GroupCommunicationMessage

java.lang.Object

org.apache.reef.io.network.group.impl.GroupCommunicationMessage

public class GroupCommunicationMessage
extends Object

Group Communication Message.

Constructor Summary

Constructors

Constructor and Description
GroupCommunicationMessage(String groupName, String operName, ReefNetworkGroupCommProtos.GroupCommMessage.Type msgType, String from, int srcVersion, String to, int dstVersion, byte[][] data)

Method Summary

Methods

Modifier and Type	Method and Description
boolean	equals(Object obj)
byte[][]	getData()
String	getDestid()
String	getDestination()
String	getGroupname()
int	getMsgsCount()
String	getOperatorname()
String	getSimpleOperName()
String	getSource()
String	getSrcid()
int	getSrcVersion()
ReefNetworkGroupCommProtos.GroupCommMessage.Type	getType()
int	getVersion()
int	hashCode()
boolean	hasSrcVersion()
boolean	hasVersion()
String	toString()

Methods inherited from class java.lang.Object

getClass, notify, notifyAll, wait, wait, wait

Constructor Detail

GroupCommunicationMessage

public GroupCommunicationMessage(String groupName,
                         String operName,
                         ReefNetworkGroupCommProtos.GroupCommMessage.Type msgType,
                         String from,
                         int srcVersion,
                         String to,
                         int dstVersion,
                         byte[][] data)

Method Detail

getGroupname

public String getGroupname()

getOperatorname

public String getOperatorname()

getSimpleOperName

public String getSimpleOperName()

getType

public ReefNetworkGroupCommProtos.GroupCommMessage.Type getType()

getSrcid

public String getSrcid()

getSrcVersion

public int getSrcVersion()

getDestid

public String getDestid()

getVersion

public int getVersion()

getSource

public String getSource()

getDestination

public String getDestination()

getData

public byte[][] getData()

getMsgsCount

public int getMsgsCount()

hasVersion

public boolean hasVersion()

hasSrcVersion

public boolean hasSrcVersion()

toString

public String toString()

Overrides:

toString in class Object

equals

public boolean equals(Object obj)

Overrides:

equals in class Object

hashCode

public int hashCode()

Overrides:

hashCode in class Object