| Package | Description | 
|---|---|
| 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.hive | |
| org.apache.flume.sink.http | This package provides an HTTP sink for Flume so that events can be sent out
 to a target HTTP endpoint. | 
| org.apache.flume.sink.irc | |
| org.apache.flume.sink.kafka | |
| org.apache.flume.sink.kite | |
| org.apache.flume.sink.solr.morphline | 
| Modifier and Type | Method and Description | 
|---|---|
| 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. | 
| Modifier and Type | Method and Description | 
|---|---|
| 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() | 
| Modifier and Type | Method and Description | 
|---|---|
| Sink.Status | ElasticSearchSink. process() | 
| Modifier and Type | Method and Description | 
|---|---|
| Sink.Status | HBaseSink. process() | 
| Sink.Status | AsyncHBaseSink. process() | 
| Modifier and Type | Method and Description | 
|---|---|
| Sink.Status | HDFSEventSink. process()Pull events out of channel and send it to HDFS. | 
| Modifier and Type | Method and Description | 
|---|---|
| Sink.Status | HiveSink. process()Pull events out of channel, find corresponding HiveWriter and write to it. | 
| Modifier and Type | Method and Description | 
|---|---|
| Sink.Status | HttpSink. process() | 
| Modifier and Type | Method and Description | 
|---|---|
| Sink.Status | IRCSink. process() | 
| Modifier and Type | Method and Description | 
|---|---|
| Sink.Status | KafkaSink. process() | 
| Modifier and Type | Method and Description | 
|---|---|
| Sink.Status | DatasetSink. process() | 
| Modifier and Type | Method and Description | 
|---|---|
| Sink.Status | MorphlineSink. process() | 
Copyright © 2009-2017 Apache Software Foundation. All Rights Reserved.