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

Constructor Summary

Constructors

Constructor and Description
SparkFlumeEvent()

Method Summary

Modifier and Type	Method and Description
org.apache.flume.source.avro.AvroFlumeEvent	event()
static SparkFlumeEvent	fromAvroFlumeEvent(org.apache.flume.source.avro.AvroFlumeEvent in)
void	readExternal(java.io.ObjectInput in)
void	writeExternal(java.io.ObjectOutput out)

Methods inherited from class Object

equals, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

SparkFlumeEvent

public SparkFlumeEvent()

Method Detail

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