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

Class BroadcastSender<T>

java.lang.Object

org.apache.reef.io.network.group.impl.operators.BroadcastSender<T>

All Implemented Interfaces:

Broadcast.Sender<T>, GroupCommOperator, EventHandler<GroupCommunicationMessage>

public class BroadcastSender<T>
extends Object
implements Broadcast.Sender<T>, EventHandler<GroupCommunicationMessage>

Constructor Summary

Constructors

Constructor and Description
BroadcastSender(String groupName, String operName, String selfId, Codec<T> dataCodec, String driverId, int version, CommGroupNetworkHandler commGroupNetworkHandler, NetworkService<GroupCommunicationMessage> netService, CommunicationGroupServiceClient commGroupClient)

Method Summary

Methods

Modifier and Type	Method and Description
Class<? extends Name<String>>	getGroupName()
Class<? extends Name<String>>	getOperName()
int	getVersion()
void	initialize()
void	onNext(GroupCommunicationMessage msg) Handles an event.
void	send(T element) Send element to all receivers.
String	toString()

Methods inherited from class java.lang.Object

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

Constructor Detail

BroadcastSender

@Inject
public BroadcastSender(String groupName,
                      String operName,
                      String selfId,
                      Codec<T> dataCodec,
                      String driverId,
                      int version,
                      CommGroupNetworkHandler commGroupNetworkHandler,
                      NetworkService<GroupCommunicationMessage> netService,
                      CommunicationGroupServiceClient commGroupClient)

Method Detail

getVersion

public int getVersion()

Specified by:

getVersion in interface GroupCommOperator

initialize

public void initialize()
                throws ParentDeadException

Specified by:

initialize in interface GroupCommOperator

Throws:

ParentDeadException

getOperName

public Class<? extends Name<String>> getOperName()

Specified by:

getOperName in interface GroupCommOperator

getGroupName

public Class<? extends Name<String>> getGroupName()

Specified by:

getGroupName in interface GroupCommOperator

toString

public String toString()

Overrides:

toString in class Object

onNext

public void onNext(GroupCommunicationMessage msg)

Description copied from interface: EventHandler

Handles an event.

Specified by:

onNext in interface EventHandler<GroupCommunicationMessage>

Parameters:

msg - an event

send

public void send(T element)
          throws NetworkException,
                 InterruptedException

Description copied from interface: Broadcast.Sender

Send element to all receivers.

Specified by:

send in interface Broadcast.Sender<T>

Throws:

NetworkException

InterruptedException