Package | Description |
---|---|
org.apache.flume.client.avro | |
org.apache.flume.serialization | |
org.apache.flume.sink.hdfs | |
org.apache.flume.sink.solr.morphline |
Class and Description |
---|
DecodeErrorPolicy |
Class and Description |
---|
AbstractAvroEventSerializer
This is a helper class provided to make it straightforward to serialize
Flume events into Avro data.
|
AvroEventDeserializer.AvroSchemaType |
DecodeErrorPolicy |
DurablePositionTracker
Class that stores object state in an avro container file.
|
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. |
EventDeserializerType |
EventSerDe
A class that is able to both serialize and deserialize events.
|
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. |
EventSerializerType |
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.
|
ResettableInputStream
This abstract class defines an interface for which
the stream may be
mark ed and reset with no limit to
the number of bytes which may have been read between the calls. |
Seekable |
Class and Description |
---|
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. |
Class and Description |
---|
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. |
Resettable
Defines an API for objects that can be mark()ed and reset() on arbitrary
boundaries.
|
ResettableInputStream
This abstract class defines an interface for which
the stream may be
mark ed and reset with no limit to
the number of bytes which may have been read between the calls. |
Copyright © 2009–2019 Apache Software Foundation. All rights reserved.