| Package | Description | 
|---|---|
| org.apache.reef.io.network.naming.serialization | 
 Contains naming serialization codecs 
 | 
| org.apache.reef.wake.remote.impl | |
| org.apache.reef.wake.remote.transport | |
| org.apache.reef.wake.remote.transport.netty | 
| Modifier and Type | Method and Description | 
|---|---|
Link<byte[]> | 
NamingMessage.getLink()
Gets a link 
 | 
| Modifier and Type | Method and Description | 
|---|---|
void | 
NamingMessage.setLink(Link<byte[]> link)
Sets the link 
 | 
| Modifier and Type | Method and Description | 
|---|---|
Link<byte[]> | 
TransportEvent.getLink()
Returns the link associated with the event
 which can be used to write back to the client
 without creating a new link 
 | 
| Constructor and Description | 
|---|
TransportEvent(byte[] data,
                            Link<byte[]> link)
Constructs the transport even object using link to
 initialize local and remote address if link not null 
 | 
| Modifier and Type | Method and Description | 
|---|---|
<T> Link<T> | 
Transport.get(SocketAddress remoteAddr)
Returns a link for the remote address if already cached; otherwise, returns null 
 | 
<T> Link<T> | 
Transport.open(SocketAddress remoteAddr,
        Encoder<? super T> encoder,
        LinkListener<? super T> listener)
Returns a link for the remote address if cached; otherwise opens, caches and returns
 When it opens a link for the remote address, only one attempt for the address is made at a given time 
 | 
| Modifier and Type | Class and Description | 
|---|---|
class  | 
NettyLink<T>
Link implementation with Netty 
 | 
| Modifier and Type | Method and Description | 
|---|---|
<T> Link<T> | 
NettyMessagingTransport.get(SocketAddress remoteAddr)
Returns a link for the remote address if already cached; otherwise, returns null 
 | 
<T> Link<T> | 
NettyMessagingTransport.open(SocketAddress remoteAddr,
        Encoder<? super T> encoder,
        LinkListener<? super T> listener)
Returns a link for the remote address if cached; otherwise opens, caches and returns
 When it opens a link for the remote address, only one attempt for the address is made at a given time 
 | 
Copyright © 2015 The Apache Software Foundation. All rights reserved.