public class SocketTeeWriter extends Object implements PipelineableWriter
ChukwaWriter.COMMIT_PENDING, ChukwaWriter.CommitStatus
Modifier and Type | Field and Description |
---|---|
static String |
RAW |
static String |
WRITABLE |
COMMIT_FAIL, COMMIT_OK
Constructor and Description |
---|
SocketTeeWriter() |
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 c)
Called once to initialize this writer.
|
void |
setNextStage(ChukwaWriter next) |
public static final String WRITABLE
public static final String RAW
public void setNextStage(ChukwaWriter next)
setNextStage
in interface PipelineableWriter
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 c) throws WriterException
ChukwaWriter
init
in interface ChukwaWriter
WriterException
Copyright © ${year} The Apache Software Foundation