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 |
EmbeddedSource
Simple 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
Channel implementation that uses the local file system for
its storage. |
class |
Log
Stores FlumeEvents on disk and pointers to the events in a in memory queue.
|
class |
LogFile |
class |
LogFileV3
Represents a single data file on disk.
|
class |
Serialization |
class |
TransactionEventRecord
Base 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 |
EventReader
A line reader produces a stream of lines for the
AvroCLIClient to
ingest into Flume. |
interface |
ReliableEventReader
A reliable event reader.
|
class |
ReliableSpoolingFileEventReader
A
ReliableEventReader which reads log data from files stored
in a spooling directory and renames each file once all of its data has been
read (through EventDeserializer.readEvent() calls). |
static class |
ReliableSpoolingFileEventReader.TrackingPolicy |
class |
SimpleTextLineEventReader
A
EventReader implementation which delegates to a
BufferedReader . |
Modifier and Type | Class and Description |
---|---|
class |
PathManagerType |
Modifier and Type | Class and Description |
---|---|
class |
DecodeErrorPolicy |
class |
DurablePositionTracker
Class that stores object state in an avro container file.
|
class |
EventDeserializerFactory |
class |
EventDeserializerType |
class |
EventSerializerFactory |
class |
EventSerializerType |
class |
LineDeserializer
A deserializer that parses text lines from a file.
|
interface |
PositionTracker
Defines an interface for tracking the offset position in a target file.
|
class |
ResettableFileInputStream
This class makes the following assumptions:
|
Modifier and Type | Class and Description |
---|---|
class |
AbstractHDFSWriter |
interface |
HDFSWriter |
Modifier and Type | Class and Description |
---|---|
class |
BlobDeserializer
A 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 |
TaildirMatcher
Identifies and caches the files matched by single file pattern for
TAILDIR source. |
Modifier and Type | Class and Description |
---|---|
class |
TwitterSource
Demo 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–2019 Apache Software Foundation. All rights reserved.