Package | Description |
---|---|
org.apache.hadoop.chukwa.datacollection.test | |
org.apache.hadoop.chukwa.datacollection.writer | |
org.apache.hadoop.chukwa.datacollection.writer.gora |
Package dedicated to using Apache Gora
as a pipeline writer implementation.
|
org.apache.hadoop.chukwa.datacollection.writer.hbase | |
org.apache.hadoop.chukwa.datacollection.writer.localfs | |
org.apache.hadoop.chukwa.datacollection.writer.parquet | |
org.apache.hadoop.chukwa.datacollection.writer.solr |
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 |
GoraWriter.add(List<Chunk> chunks) |
void |
GoraWriter.close()
If the
DataStore instance is not null, we
execute a DataStore.flush() . |
void |
GoraWriter.init(org.apache.hadoop.conf.Configuration c)
DataStore objects are created from a factory. |
Constructor and Description |
---|
GoraWriter()
Default constructor for this class.
|
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) |
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 © 2016 Apache Software Foundation. All Rights Reserved.