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

Class ScatterEncoder

java.lang.Object

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

public final class ScatterEncoder
extends Object

Encode messages for a scatter operation, which can be decoded by ScatterDecoder.

Method Summary

Modifier and Type	Method and Description
<T> Map<String,byte[]>	encode(List<T> elements, List<Integer> counts, List<? extends Identifier> taskOrder, Codec<T> dataCodec)

Methods inherited from class java.lang.Object

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

Method Detail

encode

public <T> Map<String,byte[]> encode(List<T> elements,
                                     List<Integer> counts,
                                     List<? extends Identifier> taskOrder,
                                     Codec<T> dataCodec)