| Package | Description | 
|---|---|
| org.apache.flume | |
| org.apache.flume.agent.embedded | This package provides Flume users the ability to embed simple agents
 in applications. | 
| org.apache.flume.channel | |
| org.apache.flume.channel.file | |
| org.apache.flume.channel.jdbc | |
| org.apache.flume.channel.kafka | |
| 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 | |
| org.apache.flume.source | |
| org.apache.flume.source.avroLegacy | |
| org.apache.flume.source.http | |
| org.apache.flume.source.jms | |
| org.apache.flume.source.kafka | |
| org.apache.flume.source.scribe | |
| org.apache.flume.source.taildir | |
| org.apache.flume.source.thriftLegacy | |
| org.apache.flume.source.twitter | 
| Modifier and Type | Interface and Description | 
|---|---|
| interface  | Channel | 
| interface  | ChannelSelector
 Allows the selection of a subset of channels from the given set based on
 its implementation policy. | 
| interface  | EventDrivenSource | 
| interface  | PollableSource | 
| interface  | Sink
 A sink is connected to a Channel and consumes its contents,
 sending them to a configured destination that may vary according to
 the sink type. | 
| interface  | Source
 A source generates  and calls methods on the
 configured  ChannelProcessorto persist those events into the
 configured channels. | 
| Modifier and Type | Class and Description | 
|---|---|
| class  | EmbeddedSourceSimple source used to allow direct access to the channel for the Embedded
 Agent. | 
| Modifier and Type | Class and Description | 
|---|---|
| class  | AbstractChannel | 
| class  | AbstractChannelSelector | 
| class  | BasicChannelSemantics
 An implementation of basic  Channelsemantics, including the
 implied thread-local semantics of theTransactionclass,
 which is required to extendBasicTransactionSemantics. | 
| class  | MemoryChannel
 MemoryChannel is the recommended channel to use when speeds which
 writing to disk is impractical is required or durability of data is not
 required. | 
| class  | MultiplexingChannelSelector | 
| class  | PseudoTxnMemoryChannel
 A capacity-capped  Channelimplementation that supports in-memory
 buffering and delivery of events. | 
| class  | ReplicatingChannelSelectorReplicating channel selector. | 
| class  | SpillableMemoryChannel
 SpillableMemoryChannel will use main memory for buffering events until it has reached capacity. | 
| Modifier and Type | Class and Description | 
|---|---|
| class  | FileChannel
 A durable  Channelimplementation that uses the local file system for
 its storage. | 
| Modifier and Type | Class and Description | 
|---|---|
| class  | JdbcChannel
 A JDBC based channel implementation. | 
| Modifier and Type | Class and Description | 
|---|---|
| class  | KafkaChannel | 
| Modifier and Type | Class and Description | 
|---|---|
| class  | AbstractRpcSinkThis sink provides the basic RPC functionality for Flume. | 
| class  | AbstractSink | 
| class  | AvroSink
 A  Sinkimplementation that can send events to an RPC server (such as
 Flume'sAvroSource). | 
| class  | LoggerSink
 A  Sinkimplementation that logs all events received at the INFO level
 to the org.apache.flume.sink.LoggerSink logger. | 
| class  | NullSink
 A  Sinkimplementation that simply discards all events it receives. | 
| class  | RollingFileSink | 
| class  | ThriftSink
 A  Sinkimplementation that can send events to an RPC server (such as
 Flume'sThriftSource). | 
| Modifier and Type | Class and Description | 
|---|---|
| class  | ElasticSearchSinkA sink which reads events from a channel and writes them to ElasticSearch
 based on the work done by https://github.com/Aconex/elasticflume.git. | 
| Modifier and Type | Class and Description | 
|---|---|
| class  | AsyncHBaseSinkA simple sink which reads events from a channel and writes them to HBase. | 
| class  | HBaseSinkA simple sink which reads events from a channel and writes them to HBase. | 
| Modifier and Type | Class and Description | 
|---|---|
| class  | HDFSEventSink | 
| Modifier and Type | Class and Description | 
|---|---|
| class  | HiveSink | 
| Modifier and Type | Class and Description | 
|---|---|
| class  | HttpSinkImplementation of an HTTP sink. | 
| Modifier and Type | Class and Description | 
|---|---|
| class  | IRCSink | 
| Modifier and Type | Class and Description | 
|---|---|
| class  | KafkaSinkA Flume Sink that can publish messages to Kafka. | 
| Modifier and Type | Class and Description | 
|---|---|
| class  | DatasetSinkSink that writes events to a Kite Dataset. | 
| Modifier and Type | Class and Description | 
|---|---|
| class  | MorphlineSinkFlume sink that extracts search documents from Flume events and processes them using a morphline
  Commandchain. | 
| class  | MorphlineSolrSinkFlume sink that extracts search documents from Flume events, processes them using a morphline
  Commandchain, and loads them into Apache Solr. | 
| Modifier and Type | Class and Description | 
|---|---|
| class  | AbstractEventDrivenSourceBase class which ensures sub-classes will inherit all the properties
 of BasicSourceSemantics. | 
| class  | AbstractPollableSourceBase class which ensures sub-classes will inherit all the properties
 of BasicSourceSemantics in addition to:
 
 Ensuring when configure/start throw an exception process will not
 be called
 Ensure that process will not be called unless configure and start
 have successfully been called
  | 
| class  | AbstractSource | 
| class  | AvroSource
 A  Sourceimplementation that receives Avro events from clients that
 implementAvroSourceProtocol. | 
| class  | BasicSourceSemanticsAlternative to AbstractSource, which:
 
  Ensure configure cannot be called while started
  Exceptions thrown during configure, start, stop put source in ERROR state
  Exceptions thrown during start, stop will be logged but not re-thrown.
  Exception in configure disables starting
  | 
| class  | ExecSource
 A  Sourceimplementation that executes a Unix process and turns each
 line of text into an event. | 
| class  | MultiportSyslogTCPSource | 
| class  | NetcatSource
 A netcat-like source that listens on a given port and turns each line of text
 into an event. | 
| class  | NetcatUdpSource | 
| class  | SequenceGeneratorSource | 
| class  | SpoolDirectorySource | 
| class  | StressSourceStressSource is an internal load-generating source implementation
 which is very useful for stress tests. | 
| class  | SyslogTcpSourceDeprecated. 
 use  MultiportSyslogTCPSourceinstead. | 
| class  | SyslogUDPSource | 
| class  | ThriftSource | 
| Modifier and Type | Class and Description | 
|---|---|
| class  | AvroLegacySource
 A  Sourceimplementation that receives Avro events from Avro sink of
 Flume OG | 
| Modifier and Type | Class and Description | 
|---|---|
| class  | HTTPSourceA source which accepts Flume Events by HTTP POST and GET. | 
| Modifier and Type | Class and Description | 
|---|---|
| class  | JMSSource | 
| Modifier and Type | Class and Description | 
|---|---|
| class  | KafkaSourceA Source for Kafka which reads messages from kafka topics. | 
| Modifier and Type | Class and Description | 
|---|---|
| class  | ScribeSourceFlume should adopt the Scribe entry  LogEntryfrom existing
 Scribe system. | 
| Modifier and Type | Class and Description | 
|---|---|
| class  | TaildirSource | 
| Modifier and Type | Class and Description | 
|---|---|
| class  | ThriftLegacySource | 
| Modifier and Type | Class and Description | 
|---|---|
| class  | TwitterSourceDemo Flume source that connects via Streaming API to the 1% sample twitter
 firehose, continuously downloads tweets, converts them to Avro format and
 sends Avro events to a downstream Flume sink. | 
Copyright © 2009-2017 Apache Software Foundation. All Rights Reserved.