org.apache.flume.sink.hdfs
Class HDFSWritableFormatter

java.lang.Object
  org.apache.flume.sink.hdfs.HDFSWritableFormatter

All Implemented Interfaces:

FlumeFormatter

public class HDFSWritableFormatter
extends Object
implements FlumeFormatter

Constructor Summary

HDFSWritableFormatter()

Method Summary

byte[]	getBytes(Event e)
Object	getKey(Event e)
Class<org.apache.hadoop.io.LongWritable>	getKeyClass()
Object	getValue(Event e)
Class<org.apache.hadoop.io.BytesWritable>	getValueClass()

Methods inherited from class java.lang.Object

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

Constructor Detail

HDFSWritableFormatter

public HDFSWritableFormatter()

Method Detail

getKeyClass

public Class<org.apache.hadoop.io.LongWritable> getKeyClass()

Specified by:

getKeyClass in interface FlumeFormatter

getValueClass

public Class<org.apache.hadoop.io.BytesWritable> getValueClass()

Specified by:

getValueClass in interface FlumeFormatter

getKey

public Object getKey(Event e)

Specified by:

getKey in interface FlumeFormatter

getValue

public Object getValue(Event e)

Specified by:

getValue in interface FlumeFormatter

getBytes

public byte[] getBytes(Event e)

Specified by:

getBytes in interface FlumeFormatter