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

Class CommunicationGroupDriverFactory

java.lang.Object

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

public final class CommunicationGroupDriverFactory
extends Object

A factory used to create CommunicationGroupDriver instance. Uses Tang to instantiate new object.

Method Summary

Methods

Modifier and Type	Method and Description
CommunicationGroupDriver	getNewInstance(Class<? extends Name<String>> groupName, Class<? extends Topology> topologyClass, BroadcastingEventHandler<GroupCommunicationMessage> commGroupMessageHandler, int numberOfTasks, int customFanOut) Deprecated. in 0.14. Instantiates a new CommunicationGroupDriver instance.
CommunicationGroupDriver	getNewInstance(Class<? extends Name<String>> groupName, Class<? extends Topology> topologyClass, int numberOfTasks, int customFanOut) Instantiates a new CommunicationGroupDriver instance.

Methods inherited from class java.lang.Object

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

Method Detail

getNewInstance

@Deprecated
public CommunicationGroupDriver getNewInstance(Class<? extends Name<String>> groupName,
                                                 Class<? extends Topology> topologyClass,
                                                 BroadcastingEventHandler<GroupCommunicationMessage> commGroupMessageHandler,
                                                 int numberOfTasks,
                                                 int customFanOut)
                                        throws InjectionException

Deprecated. in 0.14. Instantiates a new CommunicationGroupDriver instance.

Parameters:

groupName - specified name of the communication group

topologyClass - topology implementation

commGroupMessageHandler - message handler for the communication group

numberOfTasks - minimum number of tasks needed in this group before start

customFanOut - fanOut for TreeTopology

Returns:

CommunicationGroupDriver instance

Throws:

InjectionException

getNewInstance

public CommunicationGroupDriver getNewInstance(Class<? extends Name<String>> groupName,
                                      Class<? extends Topology> topologyClass,
                                      int numberOfTasks,
                                      int customFanOut)
                                        throws InjectionException

Instantiates a new CommunicationGroupDriver instance.

Parameters:

groupName - specified name of the communication group

topologyClass - topology implementation

numberOfTasks - minimum number of tasks needed in this group before start

customFanOut - fanOut for TreeTopology

Returns:

CommunicationGroupDriver instance

Throws:

InjectionException