public class WebHdfsHandler
extends io.netty.channel.SimpleChannelInboundHandler<io.netty.handler.codec.http.HttpRequest>
Modifier and Type | Field and Description |
---|---|
static String |
APPLICATION_JSON_UTF8 |
static String |
APPLICATION_OCTET_STREAM |
static EnumSet<org.apache.hadoop.fs.CreateFlag> |
EMPTY_CREATE_FLAG |
static String |
WEBHDFS_PREFIX |
static int |
WEBHDFS_PREFIX_LENGTH |
Constructor and Description |
---|
WebHdfsHandler(org.apache.hadoop.conf.Configuration conf,
org.apache.hadoop.conf.Configuration confForCreate) |
Modifier and Type | Method and Description |
---|---|
void |
channelRead0(io.netty.channel.ChannelHandlerContext ctx,
io.netty.handler.codec.http.HttpRequest req) |
void |
exceptionCaught(io.netty.channel.ChannelHandlerContext ctx,
Throwable cause) |
void |
handle(io.netty.channel.ChannelHandlerContext ctx,
io.netty.handler.codec.http.HttpRequest req) |
acceptInboundMessage, channelRead
channelActive, channelInactive, channelReadComplete, channelRegistered, channelUnregistered, channelWritabilityChanged, userEventTriggered
handlerAdded, handlerRemoved, isSharable
public static final String WEBHDFS_PREFIX
public static final int WEBHDFS_PREFIX_LENGTH
public static final String APPLICATION_OCTET_STREAM
public static final String APPLICATION_JSON_UTF8
public static final EnumSet<org.apache.hadoop.fs.CreateFlag> EMPTY_CREATE_FLAG
public WebHdfsHandler(org.apache.hadoop.conf.Configuration conf, org.apache.hadoop.conf.Configuration confForCreate) throws IOException
IOException
public void channelRead0(io.netty.channel.ChannelHandlerContext ctx, io.netty.handler.codec.http.HttpRequest req) throws Exception
channelRead0
in class io.netty.channel.SimpleChannelInboundHandler<io.netty.handler.codec.http.HttpRequest>
Exception
public void handle(io.netty.channel.ChannelHandlerContext ctx, io.netty.handler.codec.http.HttpRequest req) throws IOException, URISyntaxException
IOException
URISyntaxException
public void exceptionCaught(io.netty.channel.ChannelHandlerContext ctx, Throwable cause)
exceptionCaught
in interface io.netty.channel.ChannelHandler
exceptionCaught
in interface io.netty.channel.ChannelInboundHandler
exceptionCaught
in class io.netty.channel.ChannelInboundHandlerAdapter
Copyright © 2018 Apache Software Foundation. All Rights Reserved.