org.apache.hadoop.chukwa.datacollection.writer

Class Dedup

java.lang.Object

org.apache.hadoop.chukwa.datacollection.writer.Dedup

All Implemented Interfaces:

ChukwaWriter, PipelineableWriter

public class Dedup
extends Object
implements PipelineableWriter

Constructor Summary

Constructors

Constructor and Description
Dedup()

Method Summary

Methods

Modifier and Type	Method and Description
void	add(List<Chunk> chunks)
void	close()
void	init(org.apache.hadoop.conf.Configuration c)
void	setNextStage(ChukwaWriter next)

Methods inherited from class java.lang.Object

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

Constructor Detail

Dedup

public Dedup()

Method Detail

setNextStage

public void setNextStage(ChukwaWriter next)

Specified by:

setNextStage in interface PipelineableWriter

add

public void add(List<Chunk> chunks)
         throws WriterException

Specified by:

add in interface ChukwaWriter

Throws:

WriterException

close

public void close()
           throws WriterException

Specified by:

close in interface ChukwaWriter

Throws:

WriterException

init

public void init(org.apache.hadoop.conf.Configuration c)
          throws WriterException

Specified by:

init in interface ChukwaWriter

Throws:

WriterException