org.apache.hadoop.chukwa.datacollection.writer

Class PipelineableWriter

java.lang.Object

org.apache.hadoop.chukwa.datacollection.writer.PipelineableWriter

All Implemented Interfaces:

ChukwaWriter

Direct Known Subclasses:

Dedup, ExtractorWriter, HBaseWriter, SeqFileWriter, SocketTeeWriter, SolrWriter

public abstract class PipelineableWriter
extends Object
implements ChukwaWriter

Nested Class Summary

Nested classes/interfaces inherited from interface org.apache.hadoop.chukwa.datacollection.writer.ChukwaWriter

ChukwaWriter.COMMIT_PENDING, ChukwaWriter.CommitStatus

Field Summary

Fields

Modifier and Type	Field and Description
protected ChukwaWriter	next

Fields inherited from interface org.apache.hadoop.chukwa.datacollection.writer.ChukwaWriter

COMMIT_FAIL, COMMIT_OK

Constructor Summary

Constructors

Constructor and Description
PipelineableWriter()

Method Summary

Methods

Modifier and Type	Method and Description
ChukwaWriter.CommitStatus	add(List<Chunk> chunks) Called repeatedly with data that should be serialized.
void	setNextStage(ChukwaWriter next)

Methods inherited from class java.lang.Object

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

Methods inherited from interface org.apache.hadoop.chukwa.datacollection.writer.ChukwaWriter

close, init

Field Detail

next

protected ChukwaWriter next

Constructor Detail

PipelineableWriter

public PipelineableWriter()

Method Detail

setNextStage

public void setNextStage(ChukwaWriter next)

add

public ChukwaWriter.CommitStatus add(List<Chunk> chunks)
                              throws WriterException

Description copied from interface: ChukwaWriter

Called repeatedly with data that should be serialized. Subclasses may assume that init() will be called before any calls to add(), and that add() won't be called after close().

Specified by:

add in interface ChukwaWriter

Returns:

Throws:

WriterException