org.apache.flume.sink.hdfs
Class HDFSTextFormatter

java.lang.Object
  extended by 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


Copyright © 2009-2012 Apache Software Foundation. All Rights Reserved.