org.apache.spark.streaming
Spark streaming receiver for Flume.
A wrapper class for AvroFlumeEvent's with a custom serialization format.
This is necessary because AvroFlumeEvent uses inner data structures which are not serializable.
Spark streaming receiver for Flume.