|
||||||||||
| PREV NEXT | FRAMES NO FRAMES | |||||||||
| 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 |
AbstractRpcSink.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.hive |
|---|
| Methods in org.apache.flume.sink.hive that return Sink.Status | |
|---|---|
Sink.Status |
HiveSink.process()
Pull events out of channel, find corresponding HiveWriter and write to it. |
| 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()
|
| Uses of Sink.Status in org.apache.flume.sink.kafka |
|---|
| Methods in org.apache.flume.sink.kafka that return Sink.Status | |
|---|---|
Sink.Status |
KafkaSink.process()
|
| Uses of Sink.Status in org.apache.flume.sink.kite |
|---|
| Methods in org.apache.flume.sink.kite that return Sink.Status | |
|---|---|
Sink.Status |
DatasetSink.process()
|
| Uses of Sink.Status in org.apache.flume.sink.solr.morphline |
|---|
| Methods in org.apache.flume.sink.solr.morphline that return Sink.Status | |
|---|---|
Sink.Status |
MorphlineSink.process()
|
|
||||||||||
| PREV NEXT | FRAMES NO FRAMES | |||||||||