org.apache.spark.streaming.flume

Class EventTransformer

Object

org.apache.spark.streaming.flume.EventTransformer

All Implemented Interfaces:

Logging

public class EventTransformer
extends Object
implements Logging

A simple object that provides the implementation of readExternal and writeExternal for both the wrapper classes for Flume-style Events.

Constructor Summary

Constructors

Constructor and Description
EventTransformer()

Method Summary

Methods

Modifier and Type	Method and Description
static scala.Tuple2<java.util.HashMap<CharSequence,CharSequence>,byte[]>	readExternal(java.io.ObjectInput in)
static void	writeExternal(java.io.ObjectOutput out, java.util.Map<CharSequence,CharSequence> headers, byte[] body)

Methods inherited from class Object

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

Methods inherited from interface org.apache.spark.Logging

initializeIfNecessary, initializeLogging, isTraceEnabled, log_, log, logDebug, logDebug, logError, logError, logInfo, logInfo, logName, logTrace, logTrace, logWarning, logWarning

Constructor Detail

EventTransformer

public EventTransformer()

Method Detail

readExternal

public static scala.Tuple2<java.util.HashMap<CharSequence,CharSequence>,byte[]> readExternal(java.io.ObjectInput in)

writeExternal

public static void writeExternal(java.io.ObjectOutput out,
                 java.util.Map<CharSequence,CharSequence> headers,
                 byte[] body)