| Modifier and Type | Method and Description | 
|---|---|
| ChukwaWriter.CommitStatus | FilePerPostWriter. add(List<Chunk> chunks) | 
| void | FilePerPostWriter. init(org.apache.hadoop.conf.Configuration conf) | 
| Modifier and Type | Method and Description | 
|---|---|
| void | InMemoryWriter. add(Chunk data) | 
| void | ConsoleWriter. add(Chunk data) | 
| ChukwaWriter.CommitStatus | SocketTeeWriter. add(List<Chunk> chunks) | 
| ChukwaWriter.CommitStatus | SeqFileWriter. add(List<Chunk> chunks) | 
| ChukwaWriter.CommitStatus | PipelineStageWriter. add(List<Chunk> chunks) | 
| ChukwaWriter.CommitStatus | PipelineableWriter. add(List<Chunk> chunks) | 
| ChukwaWriter.CommitStatus | NullWriter. add(List<Chunk> chunks) | 
| ChukwaWriter.CommitStatus | InMemoryWriter. add(List<Chunk> chunks) | 
| ChukwaWriter.CommitStatus | HttpWriter. add(List<Chunk> chunks) | 
| ChukwaWriter.CommitStatus | ExtractorWriter. add(List<Chunk> chunks) | 
| ChukwaWriter.CommitStatus | Dedup. add(List<Chunk> chunks) | 
| ChukwaWriter.CommitStatus | ConsoleWriter. add(List<Chunk> chunks) | 
| ChukwaWriter.CommitStatus | ChukwaWriter. add(List<Chunk> chunks)Called repeatedly with data that should be serialized. | 
| void | SocketTeeWriter. close() | 
| void | PipelineStageWriter. close() | 
| void | NullWriter. close() | 
| void | HttpWriter. close() | 
| void | ExtractorWriter. close() | 
| void | Dedup. close() | 
| void | ChukwaWriter. close()Called once, indicating that the writer should close files and prepare
 to exit. | 
| void | SocketTeeWriter. init(org.apache.hadoop.conf.Configuration c) | 
| void | SeqFileWriter. init(org.apache.hadoop.conf.Configuration conf) | 
| void | PipelineStageWriter. init(org.apache.hadoop.conf.Configuration conf) | 
| void | NullWriter. init(org.apache.hadoop.conf.Configuration c) | 
| void | InMemoryWriter. init(org.apache.hadoop.conf.Configuration conf) | 
| void | HttpWriter. init(org.apache.hadoop.conf.Configuration c) | 
| void | ExtractorWriter. init(org.apache.hadoop.conf.Configuration c) | 
| 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)Called once to initialize this writer. | 
| Constructor and Description | 
|---|
| PipelineStageWriter() | 
| PipelineStageWriter(org.apache.hadoop.conf.Configuration conf) | 
| Modifier and Type | Method and Description | 
|---|---|
| ChukwaWriter.CommitStatus | HBaseWriter. add(List<Chunk> chunks) | 
| void | HBaseWriter. init(org.apache.hadoop.conf.Configuration conf) | 
| Modifier and Type | Method and Description | 
|---|---|
| ChukwaWriter.CommitStatus | LocalWriter. add(List<Chunk> chunks)Best effort, there's no guarantee that chunks 
  have really been written to disk | 
| void | LocalWriter. init(org.apache.hadoop.conf.Configuration conf) | 
| protected void | LocalWriter. rotate() | 
| void | LocalWriter. setup(org.apache.hadoop.conf.Configuration conf) | 
| Constructor and Description | 
|---|
| LocalWriter(org.apache.hadoop.conf.Configuration conf) | 
| Modifier and Type | Method and Description | 
|---|---|
| ChukwaWriter.CommitStatus | ChukwaParquetWriter. add(List<Chunk> chunks) | 
| void | ChukwaParquetWriter. close() | 
| void | ChukwaParquetWriter. init(org.apache.hadoop.conf.Configuration c) | 
| Constructor and Description | 
|---|
| ChukwaParquetWriter() | 
| ChukwaParquetWriter(org.apache.hadoop.conf.Configuration c) | 
| Modifier and Type | Method and Description | 
|---|---|
| ChukwaWriter.CommitStatus | SolrWriter. add(List<Chunk> chunks) | 
| void | SolrWriter. close() | 
| void | SolrWriter. init(org.apache.hadoop.conf.Configuration c) | 
| Constructor and Description | 
|---|
| SolrWriter() | 
Copyright © 2015 Apache Software Foundation. All Rights Reserved.