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, 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

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