public class PipelineStageWriter extends Object implements ChukwaWriter
ChukwaWriter.COMMIT_PENDING, ChukwaWriter.CommitStatus
COMMIT_FAIL, COMMIT_OK
Constructor and Description |
---|
PipelineStageWriter() |
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 ChukwaWriter.CommitStatus add(List<Chunk> chunks) throws WriterException
ChukwaWriter
add
in interface ChukwaWriter
WriterException
public void close() throws WriterException
ChukwaWriter
close
in interface ChukwaWriter
WriterException
public void init(org.apache.hadoop.conf.Configuration conf) throws WriterException
ChukwaWriter
init
in interface ChukwaWriter
WriterException
Copyright © ${year} The Apache Software Foundation