Package org.apache.flume.serialization

Interface Summary
EventDeserializer Establishes a contract for reading events stored in arbitrary formats from reliable, resettable streams.
EventDeserializer.Builder Knows how to construct this deserializer.
Note: Implementations MUST provide a public a no-arg constructor.
EventSerDe

A class that is able to both serialize and deserialize events.

EventSerDe.Builder Knows how to construct this serde.
Note: Implementations MUST provide a public a no-arg constructor.
EventSerializer This interface provides callbacks for important serialization-related events.
EventSerializer.Builder Knows how to construct this event serializer.
Note: Implementations MUST provide a public a no-arg constructor.
LengthMeasurable  
PositionTracker Defines an interface for tracking the offset position in a target file.
RemoteMarkable Allows for calling mark() without a seek()
Resettable Defines an API for objects that can be mark()ed and reset() on arbitrary boundaries.
Seekable  
 

Class Summary
AbstractAvroEventSerializer<T> This is a helper class provided to make it straightforward to serialize Flume events into Avro data.
AvroEventDeserializer A deserializer that parses Avro container files, generating one Flume event per record in the Avro file, and storing binary avro-encoded records in the Flume event body.
AvroEventDeserializer.Builder  
AvroEventSerializerConfigurationConstants  
BodyTextEventSerializer This class simply writes the body of the event to the output stream and appends a newline after each event.
BodyTextEventSerializer.Builder  
DurablePositionTracker

Class that stores object state in an avro container file.

EventDeserializerFactory  
EventSerializerFactory  
FlumeEventAvroEventSerializer  
FlumeEventAvroEventSerializer.Builder  
HeaderAndBodyTextEventSerializer This class simply writes the body of the event to the output stream and appends a newline after each event.
HeaderAndBodyTextEventSerializer.Builder  
LineDeserializer A deserializer that parses text lines from a file.
LineDeserializer.Builder  
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.

ResettableInputStream This abstract class defines an interface for which the stream may be marked and reset with no limit to the number of bytes which may have been read between the calls.
 

Enum Summary
AvroEventDeserializer.AvroSchemaType  
DecodeErrorPolicy  
EventDeserializerType  
EventSerializerType  
 



Copyright © 2009-2015 Apache Software Foundation. All Rights Reserved.