org.apache.spark.streaming.flume
Class SparkFlumeEvent
Object
org.apache.spark.streaming.flume.SparkFlumeEvent
- All Implemented Interfaces:
- java.io.Externalizable, java.io.Serializable
public class SparkFlumeEvent
- extends Object
- implements java.io.Externalizable
A wrapper class for AvroFlumeEvent's with a custom serialization format.
This is necessary because AvroFlumeEvent uses inner data structures
which are not serializable.
- See Also:
- Serialized Form
Methods inherited from class Object |
equals, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
SparkFlumeEvent
public SparkFlumeEvent()
fromAvroFlumeEvent
public static SparkFlumeEvent fromAvroFlumeEvent(org.apache.flume.source.avro.AvroFlumeEvent in)
event
public org.apache.flume.source.avro.AvroFlumeEvent event()
readExternal
public void readExternal(java.io.ObjectInput in)
- Specified by:
readExternal
in interface java.io.Externalizable
writeExternal
public void writeExternal(java.io.ObjectOutput out)
- Specified by:
writeExternal
in interface java.io.Externalizable