org.apache.spark.streaming.flume

Class FlumeReceiver.CompressionChannelPipelineFactory

Object

org.apache.spark.streaming.flume.FlumeReceiver.CompressionChannelPipelineFactory

All Implemented Interfaces:

org.jboss.netty.channel.ChannelPipelineFactory

Enclosing class:

FlumeReceiver

public class FlumeReceiver.CompressionChannelPipelineFactory
extends Object
implements org.jboss.netty.channel.ChannelPipelineFactory

A Netty Pipeline factory that will decompress incoming data from and the Netty client and compress data going back to the client.

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 Summary

Constructors

Constructor and Description
FlumeReceiver.CompressionChannelPipelineFactory()

Method Summary

Methods

Modifier and Type	Method and Description
org.jboss.netty.channel.ChannelPipeline	getPipeline()

Methods inherited from class Object

equals, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

FlumeReceiver.CompressionChannelPipelineFactory

public FlumeReceiver.CompressionChannelPipelineFactory()

Method Detail

getPipeline

public org.jboss.netty.channel.ChannelPipeline getPipeline()

Specified by:

getPipeline in interface org.jboss.netty.channel.ChannelPipelineFactory