org.apache.flume.sink.hdfs
Class HDFSTextFormatter

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

All Implemented Interfaces:

FlumeFormatter

public class HDFSTextFormatter
extends Object
implements FlumeFormatter

Constructor Summary

HDFSTextFormatter()

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.Text>	getValueClass()

Methods inherited from class java.lang.Object

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

Constructor Detail

HDFSTextFormatter

public HDFSTextFormatter()

Method Detail

getKeyClass

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

Specified by:

getKeyClass in interface FlumeFormatter

getValueClass

public Class<org.apache.hadoop.io.Text> 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