public class RequestEncoder
extends io.netty.channel.ChannelOutboundHandlerAdapter
Constructor and Description |
---|
RequestEncoder(GiraphConfiguration conf)
Constructor.
|
Modifier and Type | Method and Description |
---|---|
void |
write(io.netty.channel.ChannelHandlerContext ctx,
Object msg,
io.netty.channel.ChannelPromise promise) |
bind, close, connect, deregister, disconnect, flush, read
ensureNotSharable, exceptionCaught, handlerAdded, handlerRemoved, isSharable
public RequestEncoder(GiraphConfiguration conf)
conf
- Giraph configurationpublic void write(io.netty.channel.ChannelHandlerContext ctx, Object msg, io.netty.channel.ChannelPromise promise) throws Exception
write
in interface io.netty.channel.ChannelOutboundHandler
write
in class io.netty.channel.ChannelOutboundHandlerAdapter
Exception
Copyright © 2011-2020 The Apache Software Foundation. All Rights Reserved.