Modifier and Type | Method and Description |
---|---|
ChukwaWriter.CommitStatus |
FilePerPostWriter.add(List<Chunk> chunks) |
Modifier and Type | Class and Description |
---|---|
static class |
ChukwaWriter.COMMIT_PENDING
COMMIT_PENDING should be returned if a writer has written data, but
this data may ultimately disappear.
|
Modifier and Type | Field and Description |
---|---|
static ChukwaWriter.CommitStatus |
ChukwaWriter.COMMIT_FAIL |
static ChukwaWriter.CommitStatus |
ChukwaWriter.COMMIT_OK |
Modifier and Type | Method and Description |
---|---|
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 |
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.
|
Modifier and Type | Method and Description |
---|---|
ChukwaWriter.CommitStatus |
HBaseWriter.add(List<Chunk> chunks) |
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
|
Modifier and Type | Method and Description |
---|---|
ChukwaWriter.CommitStatus |
SolrWriter.add(List<Chunk> chunks) |
Copyright © 2014 Apache Software Foundation. All Rights Reserved.