|
||||||||||
PREV NEXT | FRAMES NO FRAMES |
Uses of InterfaceStability.Evolving in org.apache.flume.annotations |
---|
Classes in org.apache.flume.annotations with annotations of type InterfaceStability.Evolving | |
---|---|
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. |
Uses of InterfaceStability.Evolving in org.apache.flume.client.avro |
---|
Classes in org.apache.flume.client.avro with annotations of type InterfaceStability.Evolving | |
---|---|
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 . |
Uses of InterfaceStability.Evolving in org.apache.flume.serialization |
---|
Classes in org.apache.flume.serialization with annotations of type InterfaceStability.Evolving | |
---|---|
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: The underlying file is not changing while it is being read The ability to ResettableFileInputStream.reset() is dependent on the underlying PositionTracker instance's durability semantics. |
Uses of InterfaceStability.Evolving in org.apache.flume.sink.hdfs |
---|
Classes in org.apache.flume.sink.hdfs with annotations of type InterfaceStability.Evolving | |
---|---|
class |
AbstractHDFSWriter
|
interface |
HDFSWriter
|
Uses of InterfaceStability.Evolving in org.apache.flume.sink.solr.morphline |
---|
Classes in org.apache.flume.sink.solr.morphline with annotations of type InterfaceStability.Evolving | |
---|---|
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. |
Uses of InterfaceStability.Evolving in org.apache.flume.source |
---|
Classes in org.apache.flume.source with annotations of type InterfaceStability.Evolving | |
---|---|
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 |
|
||||||||||
PREV NEXT | FRAMES NO FRAMES |