void |
SeqFileWriter.add(Chunk chunk) |
void |
InMemoryWriter.add(Chunk data) |
void |
ConsoleWriter.add(Chunk data) |
void |
SeqFileWriter.add(List<Chunk> chunks) |
void |
PipelineStageWriter.add(List<Chunk> chunks) |
void |
InMemoryWriter.add(List<Chunk> chunks) |
void |
Dedup.add(List<Chunk> chunks) |
void |
ConsoleWriter.add(List<Chunk> chunks) |
void |
ChukwaWriter.add(List<Chunk> chunks) |
void |
PipelineStageWriter.close() |
void |
Dedup.close() |
void |
ChukwaWriter.close() |
void |
SeqFileWriter.init(org.apache.hadoop.conf.Configuration conf) |
void |
PipelineStageWriter.init(org.apache.hadoop.conf.Configuration conf) |
void |
InMemoryWriter.init(org.apache.hadoop.conf.Configuration conf) |
void |
Dedup.init(org.apache.hadoop.conf.Configuration c) |
void |
ConsoleWriter.init(org.apache.hadoop.conf.Configuration conf) |
void |
ChukwaWriter.init(org.apache.hadoop.conf.Configuration c) |