Package | Description |
---|---|
org.apache.reef.io.network.naming.serialization |
Contains naming serialization codecs.
|
org.apache.reef.wake.remote.impl |
Implementations for Wake's remote communication.
|
org.apache.reef.wake.remote.transport |
Wake's remote transportation.
|
org.apache.reef.wake.remote.transport.netty |
Netty-based remote transport implementation.
|
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.
|
Constructor and Description |
---|
TransportEvent(byte[] data,
Link<byte[]> link)
Constructs the transport even object using link to.
|
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.
|
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.
|
Copyright © 2017 The Apache Software Foundation. All rights reserved.