public class PipelineStageWriter extends Object implements ChukwaWriter
ChukwaWriter.COMMIT_PENDING, ChukwaWriter.CommitStatus
COMMIT_FAIL, COMMIT_OK
Constructor and Description |
---|
PipelineStageWriter() |
PipelineStageWriter(org.apache.hadoop.conf.Configuration conf) |
Modifier and Type | Method and Description |
---|---|
ChukwaWriter.CommitStatus |
add(List<Chunk> chunks)
Called repeatedly with data that should be serialized.
|
void |
close()
Called once, indicating that the writer should close files and prepare
to exit.
|
void |
init(org.apache.hadoop.conf.Configuration conf)
Called once to initialize this writer.
|
public PipelineStageWriter() throws WriterException
WriterException
public PipelineStageWriter(org.apache.hadoop.conf.Configuration conf) throws WriterException
WriterException
public ChukwaWriter.CommitStatus add(List<Chunk> chunks) throws WriterException
ChukwaWriter
add
in interface ChukwaWriter
chunks
- is a list of data to sendWriterException
- if error writing datapublic void close() throws WriterException
ChukwaWriter
close
in interface ChukwaWriter
WriterException
- if error writing datapublic void init(org.apache.hadoop.conf.Configuration conf) throws WriterException
ChukwaWriter
init
in interface ChukwaWriter
conf
- is Chukwa configurationWriterException
- if error writing dataCopyright © 2016 Apache Software Foundation. All Rights Reserved.