|
||||||||||
| PREV NEXT | FRAMES NO FRAMES | |||||||||
| Packages that use PollableSink.Status | |
|---|---|
| org.apache.flume | |
| org.apache.flume.sink | |
| org.apache.flume.sink.hdfs | |
| Uses of PollableSink.Status in org.apache.flume |
|---|
| Methods in org.apache.flume that return PollableSink.Status | |
|---|---|
PollableSink.Status |
PollableSink.process()
|
static PollableSink.Status |
PollableSink.Status.valueOf(String name)
Returns the enum constant of this type with the specified name. |
static PollableSink.Status[] |
PollableSink.Status.values()
Returns an array containing the constants of this enum type, in the order they are declared. |
| Uses of PollableSink.Status in org.apache.flume.sink |
|---|
| Methods in org.apache.flume.sink that return PollableSink.Status | |
|---|---|
PollableSink.Status |
RollingFileSink.process()
|
PollableSink.Status |
NullSink.process()
|
PollableSink.Status |
LoggerSink.process()
|
PollableSink.Status |
AvroSink.process()
|
| Uses of PollableSink.Status in org.apache.flume.sink.hdfs |
|---|
| Methods in org.apache.flume.sink.hdfs that return PollableSink.Status | |
|---|---|
PollableSink.Status |
HDFSEventSink.process()
Pull events out of channel and send it to HDFS - take at the most txnEventMax, that's the maximum #events to hold in channel for a given transaction - find the corresponding bucket for the event, ensure the file is open - extract the pay-load and append to HDFS file |
|
||||||||||
| PREV NEXT | FRAMES NO FRAMES | |||||||||