public class FlumeReceiver.CompressionChannelPipelineFactory
extends Object
implements org.jboss.netty.channel.ChannelPipelineFactory
The compression on the return is required because Flume requires a successful response to indicate it can remove the event/batch from the configured channel
Constructor and Description |
---|
FlumeReceiver.CompressionChannelPipelineFactory() |
Modifier and Type | Method and Description |
---|---|
org.jboss.netty.channel.ChannelPipeline |
getPipeline() |