Package org.apache.nemo.runtime.common
-
Interface Summary Interface Description NettyChannelImplementationSelector Selects appropriateChannel
implementation. -
Class Summary Class Description NativeChannelImplementationSelector ANettyChannelImplementationSelector
implementation that prefers native transport if possible.NioChannelImplementationSelector ANettyChannelImplementationSelector
implementation that prefers nio-based channel implementation.ReplyFutureMap<T> Orchestrate message sender and receiver usingCompletableFuture
for asynchronous request-reply communication.RuntimeIdManager ID Generator.RuntimeTestUtil Utility class for runtime unit tests.