| Class | Description |
|---|---|
| EventTransformer |
A simple object that provides the implementation of readExternal and writeExternal for both
the wrapper classes for Flume-style Events.
|
| FlumeBatchFetcher |
This class implements the core functionality of
FlumePollingReceiver. |
| FlumeConnection |
A wrapper around the transceiver and the Avro IPC API.
|
| FlumeEventServer |
A simple server that implements Flume's Avro protocol.
|
| FlumeInputDStream<T> | |
| FlumePollingInputDStream<T> |
A
ReceiverInputDStream that can be used to read data from several Flume agents running
SparkSinks. |
| FlumePollingReceiver | |
| FlumeReceiver |
A NetworkReceiver which listens for events using the
Flume Avro interface.
|
| FlumeUtils | |
| SparkFlumeEvent |
A wrapper class for AvroFlumeEvent's with a custom serialization format.
|