org.apache.flume.sink.hdfs
Class HDFSWritableFormatter

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


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