|
||||||||||
| PREV NEXT | FRAMES NO FRAMES | |||||||||
| Packages that use Sink.Status | |
|---|---|
| org.apache.flume | |
| org.apache.flume.sink | |
| org.apache.flume.sink.elasticsearch | |
| org.apache.flume.sink.hbase | |
| org.apache.flume.sink.hdfs | |
| org.apache.flume.sink.irc | |
| Uses of Sink.Status in org.apache.flume |
|---|
| Methods in org.apache.flume that return Sink.Status | |
|---|---|
Sink.Status |
SinkProcessor.process()
Handle a request to poll the owned sinks. |
Sink.Status |
Sink.process()
Requests the sink to attempt to consume data from attached channel |
static Sink.Status |
Sink.Status.valueOf(String name)
Returns the enum constant of this type with the specified name. |
static Sink.Status[] |
Sink.Status.values()
Returns an array containing the constants of this enum type, in the order they are declared. |
| Uses of Sink.Status in org.apache.flume.sink |
|---|
| Methods in org.apache.flume.sink that return Sink.Status | |
|---|---|
Sink.Status |
RollingFileSink.process()
|
Sink.Status |
NullSink.process()
|
Sink.Status |
LoggerSink.process()
|
Sink.Status |
LoadBalancingSinkProcessor.process()
|
Sink.Status |
FailoverSinkProcessor.process()
|
Sink.Status |
DefaultSinkProcessor.process()
|
Sink.Status |
AvroSink.process()
|
| Uses of Sink.Status in org.apache.flume.sink.elasticsearch |
|---|
| Methods in org.apache.flume.sink.elasticsearch that return Sink.Status | |
|---|---|
Sink.Status |
ElasticSearchSink.process()
|
| Uses of Sink.Status in org.apache.flume.sink.hbase |
|---|
| Methods in org.apache.flume.sink.hbase that return Sink.Status | |
|---|---|
Sink.Status |
HBaseSink.process()
|
Sink.Status |
AsyncHBaseSink.process()
|
| Uses of Sink.Status in org.apache.flume.sink.hdfs |
|---|
| Methods in org.apache.flume.sink.hdfs that return Sink.Status | |
|---|---|
Sink.Status |
HDFSEventSink.process()
Pull events out of channel and send it to HDFS. |
| Uses of Sink.Status in org.apache.flume.sink.irc |
|---|
| Methods in org.apache.flume.sink.irc that return Sink.Status | |
|---|---|
Sink.Status |
IRCSink.process()
|
|
||||||||||
| PREV NEXT | FRAMES NO FRAMES | |||||||||