org.apache.reef.io.network.impl

Class NetworkService<T>

java.lang.Object

org.apache.reef.io.network.impl.NetworkService<T>

All Implemented Interfaces:

AutoCloseable, ConnectionFactory<T>, Stage

public final class NetworkService<T>
extends Object
implements Stage, ConnectionFactory<T>

Network service for Task.

Method Summary

Methods

Modifier and Type	Method and Description
void	close()
Codec<T>	getCodec()
Identifier	getConnectionFactoryId()
IdentifierFactory	getIdentifierFactory()
Identifier	getLocalEndPointId() Each connection factory has own local end point id.
Identifier	getMyId()
Naming	getNameClient()
Transport	getTransport()
Connection<T>	newConnection(Identifier destId) Creates a new connection.
void	registerId(Identifier id)
void	unregisterId(Identifier id)

Methods inherited from class java.lang.Object

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

Method Detail

registerId

public void registerId(Identifier id)

unregisterId

public void unregisterId(Identifier id)

getMyId

public Identifier getMyId()

getTransport

public Transport getTransport()

getCodec

public Codec<T> getCodec()

getNameClient

public Naming getNameClient()

getIdentifierFactory

public IdentifierFactory getIdentifierFactory()

close

public void close()
           throws Exception

Specified by:

close in interface AutoCloseable

Throws:

Exception

newConnection

public Connection<T> newConnection(Identifier destId)

Description copied from interface: ConnectionFactory

Creates a new connection.

Specified by:

newConnection in interface ConnectionFactory<T>

Parameters:

destId - a destination identifier

Returns:

a connection

getConnectionFactoryId

public Identifier getConnectionFactoryId()

Specified by:

getConnectionFactoryId in interface ConnectionFactory<T>

Returns:

the connection factory identifier.

getLocalEndPointId

public Identifier getLocalEndPointId()

Description copied from interface: ConnectionFactory

Each connection factory has own local end point id. If connections are created by the connection factory, the local end point id is used as the source id of all the connections. It returns the local end point id.

Specified by:

getLocalEndPointId in interface ConnectionFactory<T>

Returns:

the local end point id