public class SocketTeeWriter extends PipelineableWriter
ChukwaWriter.COMMIT_PENDING, ChukwaWriter.CommitStatus
Modifier and Type | Field and Description |
---|---|
static String |
ASCII_HEADER |
static int |
DEFAULT_PORT |
static String |
RAW |
static String |
WRITABLE |
next
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 static final String ASCII_HEADER
public static final int DEFAULT_PORT
public void setNextStage(ChukwaWriter next)
setNextStage
in class PipelineableWriter
public ChukwaWriter.CommitStatus add(List<Chunk> chunks) throws WriterException
ChukwaWriter
add
in interface ChukwaWriter
add
in class PipelineableWriter
WriterException
public void close() throws WriterException
ChukwaWriter
WriterException
public void init(org.apache.hadoop.conf.Configuration c) throws WriterException
ChukwaWriter
WriterException
Copyright © 2015 Apache Software Foundation. All Rights Reserved.