Modifier and Type | Class and Description |
---|---|
class |
InterfaceAudience
Annotation to inform users of a package, class or method's intended audience.
|
class |
InterfaceStability
Annotation to inform users of how much to rely on a particular package,
class or method not changing over time.
|
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 |
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). |
class |
SimpleTextLineEventReader
A
EventReader implementation which delegates to a
BufferedReader . |
Modifier and Type | Class and Description |
---|---|
class |
DecodeErrorPolicy |
class |
DurablePositionTracker
Class that stores object state in an avro container file.
|
interface |
EventDeserializer
Establishes a contract for reading events stored in arbitrary formats from
reliable, resettable streams.
|
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.
|
interface |
Resettable
Defines an API for objects that can be mark()ed and reset() on arbitrary
boundaries.
|
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 |
AbstractEventDrivenSource
Base class which ensures sub-classes will inherit all the properties
of BasicSourceSemantics.
|
class |
AbstractPollableSource
Base 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 |
BasicSourceSemantics
Alternative 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 |
SyslogParser |
class |
SyslogUtils |
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 |
TimestampRoundDownUtil |
Copyright © 2009–2019 Apache Software Foundation. All rights reserved.