Used by Tasks to fetch CommunicationGroupClients. More...

Public Member Functions
	GroupCommClient ([Parameter(typeof(GroupCommConfigurationOptions.SerializedGroupConfigs))] ISet< string > groupConfigs, [Parameter(typeof(TaskConfigurationOptions.Identifier))] string taskId, StreamingNetworkService< GeneralGroupCommunicationMessage > networkService, AvroConfigurationSerializer configSerializer, IInjector injector)
	Creates a new WritableGroupCommClient and registers the task ID with the Name Server. More...

ICommunicationGroupClient	GetCommunicationGroup (string groupName)
	Gets the CommunicationGroupClient for the given group name. More...

void	Dispose ()
	Disposes of the GroupCommClient's services. More...

Detailed Description

Used by Tasks to fetch CommunicationGroupClients.

Writable version

Constructor & Destructor Documentation

Org.Apache.REEF.Network.Group.Task.Impl.GroupCommClient.GroupCommClient	(	[Parameter(typeof(GroupCommConfigurationOptions.SerializedGroupConfigs))] ISet< string >	groupConfigs,
		[Parameter(typeof(TaskConfigurationOptions.Identifier))] string	taskId,
		StreamingNetworkService< GeneralGroupCommunicationMessage >	networkService,
		AvroConfigurationSerializer	configSerializer,
		IInjector	injector
	)

inline

Creates a new WritableGroupCommClient and registers the task ID with the Name Server.

Parameters

groupConfigs	The set of serialized Group Communication configurations
taskId	The identifier for this task
networkService	The writable network service used to send messages
configSerializer	Used to deserialize Group Communication configuration
injector	injector forked from the injector that creates this instance

void Org.Apache.REEF.Network.Group.Task.Impl.GroupCommClient.Dispose ( )

inline

Disposes of the GroupCommClient's services.

ICommunicationGroupClient Org.Apache.REEF.Network.Group.Task.Impl.GroupCommClient.GetCommunicationGroup ( string groupName )

inline

Gets the CommunicationGroupClient for the given group name.

Parameters

groupName The name of the CommunicationGroupClient

The documentation for this class was generated from the following file: