|
||||||||||
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 |