org.apache.flume.sink.hdfs
Class HDFSSequenceFile
java.lang.Object
org.apache.flume.sink.hdfs.HDFSSequenceFile
- All Implemented Interfaces:
- HDFSWriter
public class HDFSSequenceFile
- extends Object
- implements HDFSWriter
Methods inherited from class java.lang.Object |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
HDFSSequenceFile
public HDFSSequenceFile()
open
public void open(String filePath,
FlumeFormatter fmt)
throws IOException
- Specified by:
open
in interface HDFSWriter
- Throws:
IOException
open
public void open(String filePath,
org.apache.hadoop.io.compress.CompressionCodec codeC,
org.apache.hadoop.io.SequenceFile.CompressionType compType,
FlumeFormatter fmt)
throws IOException
- Specified by:
open
in interface HDFSWriter
- Throws:
IOException
append
public void append(Event e,
FlumeFormatter formatter)
throws IOException
- Specified by:
append
in interface HDFSWriter
- Throws:
IOException
sync
public void sync()
throws IOException
- Specified by:
sync
in interface HDFSWriter
- Throws:
IOException
close
public void close()
throws IOException
- Specified by:
close
in interface HDFSWriter
- Throws:
IOException
Copyright © 2009-2012 Apache Software Foundation. All Rights Reserved.