| Package | Description | 
|---|---|
| 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.client.avro | |
| org.apache.flume.formatter.output | |
| org.apache.flume.serialization | |
| org.apache.flume.sink.hdfs | |
| org.apache.flume.sink.solr.morphline | |
| org.apache.flume.source | |
| org.apache.flume.source.jms | |
| org.apache.flume.source.taildir | |
| org.apache.flume.source.twitter | |
| org.apache.flume.tools | 
| 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  | 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. | 
| class  | LogStores FlumeEvents on disk and pointers to the events in a in memory queue. | 
| class  | LogFile | 
| class  | LogFileV3Represents a single data file on disk. | 
| class  | Serialization | 
| class  | TransactionEventRecordBase class for records in data file: Put, Take, Rollback, Commit | 
| Modifier and Type | Class and Description | 
|---|---|
| class  | JdbcChannel
 A JDBC based channel implementation. | 
| Modifier and Type | Class and Description | 
|---|---|
| class  | AvroCLIClient | 
| interface  | EventReaderA line reader produces a stream of lines for the  AvroCLIClientto
 ingest into Flume. | 
| interface  | ReliableEventReaderA reliable event reader. | 
| class  | ReliableSpoolingFileEventReaderA  ReliableEventReaderwhich reads log data from files stored
 in a spooling directory and renames each file once all of its data has been
 read (throughEventDeserializer.readEvent()calls). | 
| class  | SimpleTextLineEventReaderA  EventReaderimplementation which delegates to aBufferedReader. | 
| Modifier and Type | Class and Description | 
|---|---|
| class  | PathManagerType | 
| Modifier and Type | Class and Description | 
|---|---|
| class  | DecodeErrorPolicy | 
| class  | DurablePositionTrackerClass that stores object state in an avro container file. | 
| class  | EventDeserializerFactory | 
| class  | EventDeserializerType | 
| class  | EventSerializerFactory | 
| class  | EventSerializerType | 
| class  | LineDeserializerA deserializer that parses text lines from a file. | 
| interface  | PositionTrackerDefines an interface for tracking the offset position in a target file. | 
| class  | ResettableFileInputStreamThis class makes the following assumptions: | 
| Modifier and Type | Class and Description | 
|---|---|
| class  | AbstractHDFSWriter | 
| interface  | HDFSWriter | 
| Modifier and Type | Class and Description | 
|---|---|
| class  | BlobDeserializerA deserializer that reads a Binary Large Object (BLOB) per event, typically
 one BLOB per file; To be used in conjunction with Flume SpoolDirectorySource. | 
| Modifier and Type | Class and Description | 
|---|---|
| class  | SyslogParser | 
| class  | SyslogUtils | 
| Modifier and Type | Class and Description | 
|---|---|
| class  | JMSSource | 
| Modifier and Type | Class and Description | 
|---|---|
| class  | ReliableTaildirEventReader | 
| class  | TaildirMatcherIdentifies and caches the files matched by single file pattern for  TAILDIRsource. | 
| 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. | 
| Modifier and Type | Class and Description | 
|---|---|
| class  | TimestampRoundDownUtil | 
Copyright © 2009-2017 Apache Software Foundation. All Rights Reserved.