public class FlinkHttpObjectAggregator
extends org.apache.flink.shaded.netty4.io.netty.handler.codec.http.HttpObjectAggregator
HttpObjectDecoder
but returns HTTP 413 to the client if the payload exceeds HttpObjectAggregator.maxContentLength
.Constructor and Description |
---|
FlinkHttpObjectAggregator(int maxContentLength,
Map<String,String> responseHeaders) |
Modifier and Type | Method and Description |
---|---|
protected void |
decode(org.apache.flink.shaded.netty4.io.netty.channel.ChannelHandlerContext ctx,
org.apache.flink.shaded.netty4.io.netty.handler.codec.http.HttpObject msg,
List<Object> out) |
channelInactive, getMaxCumulationBufferComponents, handlerAdded, handlerRemoved, setMaxCumulationBufferComponents
acceptInboundMessage, channelRead
channelActive, channelReadComplete, channelRegistered, channelUnregistered, channelWritabilityChanged, exceptionCaught, userEventTriggered
protected void decode(org.apache.flink.shaded.netty4.io.netty.channel.ChannelHandlerContext ctx, org.apache.flink.shaded.netty4.io.netty.handler.codec.http.HttpObject msg, List<Object> out) throws Exception
decode
in class org.apache.flink.shaded.netty4.io.netty.handler.codec.http.HttpObjectAggregator
Exception
Copyright © 2014–2019 The Apache Software Foundation. All rights reserved.