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

Class Utils

java.lang.Object

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

public final class Utils
extends Object

Utility class for group communications.

Field Summary

Fields

Modifier and Type	Field and Description
static byte[]	EMPTY_BYTE_ARR

Method Summary

Methods

Modifier and Type	Method and Description
static GroupCommunicationMessage	bldVersionedGCM(Class<? extends Name<String>> groupName, Class<? extends Name<String>> operName, ReefNetworkGroupCommProtos.GroupCommMessage.Type msgType, String from, int srcVersion, String to, int dstVersion, byte[]... data)
static Class<? extends Name<String>>	getClass(String className)
static byte[]	getData(GroupCommunicationMessage gcm)
static GroupCommunicationMessage	getGCM(Message<GroupCommunicationMessage> msg) Extract a group communication message object from a message.
static String	simpleName(Class<?> className)

Methods inherited from class java.lang.Object

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

Field Detail

EMPTY_BYTE_ARR

public static final byte[] EMPTY_BYTE_ARR

Method Detail

bldVersionedGCM

public static GroupCommunicationMessage bldVersionedGCM(Class<? extends Name<String>> groupName,
                                        Class<? extends Name<String>> operName,
                                        ReefNetworkGroupCommProtos.GroupCommMessage.Type msgType,
                                        String from,
                                        int srcVersion,
                                        String to,
                                        int dstVersion,
                                        byte[]... data)

getClass

public static Class<? extends Name<String>> getClass(String className)

simpleName

public static String simpleName(Class<?> className)

getData

public static byte[] getData(GroupCommunicationMessage gcm)

getGCM

public static GroupCommunicationMessage getGCM(Message<GroupCommunicationMessage> msg)

Extract a group communication message object from a message.

Parameters:

msg -

Returns: