Package org.apache.nemo.runtime.common
Class NativeChannelImplementationSelector
- java.lang.Object
-
- org.apache.nemo.runtime.common.NativeChannelImplementationSelector
-
- All Implemented Interfaces:
NettyChannelImplementationSelector
public final class NativeChannelImplementationSelector extends java.lang.Object implements NettyChannelImplementationSelector
ANettyChannelImplementationSelector
implementation that prefers native transport if possible. UsesEpoll
if possible (on Linux).
-
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description java.lang.Class<? extends io.netty.channel.Channel>
getChannelClass()
java.lang.Class<? extends io.netty.channel.ServerChannel>
getServerChannelClass()
io.netty.channel.EventLoopGroup
newEventLoopGroup(int numThreads, java.util.concurrent.ThreadFactory threadFactory)
Creates a newEventLoopGroup
.
-
-
-
Method Detail
-
newEventLoopGroup
public io.netty.channel.EventLoopGroup newEventLoopGroup(int numThreads, java.util.concurrent.ThreadFactory threadFactory)
Description copied from interface:NettyChannelImplementationSelector
Creates a newEventLoopGroup
.- Specified by:
newEventLoopGroup
in interfaceNettyChannelImplementationSelector
- Parameters:
numThreads
- the number of threadsthreadFactory
- theThreadFactory
- Returns:
- a new
EventLoopGroup
-
getServerChannelClass
public java.lang.Class<? extends io.netty.channel.ServerChannel> getServerChannelClass()
- Specified by:
getServerChannelClass
in interfaceNettyChannelImplementationSelector
- Returns:
- class for server channel
-
getChannelClass
public java.lang.Class<? extends io.netty.channel.Channel> getChannelClass()
- Specified by:
getChannelClass
in interfaceNettyChannelImplementationSelector
- Returns:
- class for channel
-
-