public interface ChukwaWriter
Modifier and Type | Interface and Description |
---|---|
static class |
ChukwaWriter.COMMIT_PENDING
COMMIT_PENDING should be returned if a writer has written data, but
this data may ultimately disappear.
|
static class |
ChukwaWriter.CommitStatus |
Modifier and Type | Field and Description |
---|---|
static ChukwaWriter.CommitStatus |
COMMIT_FAIL |
static ChukwaWriter.CommitStatus |
COMMIT_OK |
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.
|
static final ChukwaWriter.CommitStatus COMMIT_OK
static final ChukwaWriter.CommitStatus COMMIT_FAIL
void init(org.apache.hadoop.conf.Configuration c) throws WriterException
c
- WriterException
ChukwaWriter.CommitStatus add(List<Chunk> chunks) throws WriterException
chunks
- WriterException
void close() throws WriterException
WriterException
Copyright © 2015 Apache Software Foundation. All Rights Reserved.