Package | Description |
---|---|
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 |
---|---|
void |
RemoteReceiverStage.onNext(TransportEvent value)
Handles the received event.
|
void |
OrderedRemoteReceiverStage.onNext(TransportEvent value) |
void |
DefaultTransportEStage.onNext(TransportEvent value) |
Modifier and Type | Method and Description |
---|---|
Transport |
TransportFactory.newInstance(int port,
EventHandler<TransportEvent> clientHandler,
EventHandler<TransportEvent> serverHandler,
EventHandler<Exception> exHandler)
Creates a transport.
|
Transport |
TransportFactory.newInstance(int port,
EventHandler<TransportEvent> clientHandler,
EventHandler<TransportEvent> serverHandler,
EventHandler<Exception> exHandler)
Creates a transport.
|
Transport |
TransportFactory.newInstance(String hostAddress,
int port,
EStage<TransportEvent> clientStage,
EStage<TransportEvent> serverStage,
int numberOfTries,
int retryTimeout)
Creates a transport.
|
Transport |
TransportFactory.newInstance(String hostAddress,
int port,
EStage<TransportEvent> clientStage,
EStage<TransportEvent> serverStage,
int numberOfTries,
int retryTimeout)
Creates a transport.
|
Transport |
TransportFactory.newInstance(String hostAddress,
int port,
EStage<TransportEvent> clientStage,
EStage<TransportEvent> serverStage,
int numberOfTries,
int retryTimeout,
TcpPortProvider tcpPortProvider)
Creates a transport.
|
Transport |
TransportFactory.newInstance(String hostAddress,
int port,
EStage<TransportEvent> clientStage,
EStage<TransportEvent> serverStage,
int numberOfTries,
int retryTimeout,
TcpPortProvider tcpPortProvider)
Creates a transport.
|
Modifier and Type | Method and Description |
---|---|
Transport |
MessagingTransportFactory.newInstance(int port,
EventHandler<TransportEvent> clientHandler,
EventHandler<TransportEvent> serverHandler,
EventHandler<Exception> exHandler)
Creates a transport.
|
Transport |
MessagingTransportFactory.newInstance(int port,
EventHandler<TransportEvent> clientHandler,
EventHandler<TransportEvent> serverHandler,
EventHandler<Exception> exHandler)
Creates a transport.
|
Transport |
MessagingTransportFactory.newInstance(String hostAddress,
int port,
EStage<TransportEvent> clientStage,
EStage<TransportEvent> serverStage,
int numberOfTries,
int retryTimeout)
Creates a transport.
|
Transport |
MessagingTransportFactory.newInstance(String hostAddress,
int port,
EStage<TransportEvent> clientStage,
EStage<TransportEvent> serverStage,
int numberOfTries,
int retryTimeout)
Creates a transport.
|
Transport |
MessagingTransportFactory.newInstance(String hostAddress,
int port,
EStage<TransportEvent> clientStage,
EStage<TransportEvent> serverStage,
int numberOfTries,
int retryTimeout,
TcpPortProvider tcpPortProvider)
Creates a transport.
|
Transport |
MessagingTransportFactory.newInstance(String hostAddress,
int port,
EStage<TransportEvent> clientStage,
EStage<TransportEvent> serverStage,
int numberOfTries,
int retryTimeout,
TcpPortProvider tcpPortProvider)
Creates a transport.
|
Copyright © 2016 The Apache Software Foundation. All rights reserved.