org.apache.flume.sink.hdfs
Class HDFSCompressedDataStream
java.lang.Object
org.apache.flume.sink.hdfs.HDFSCompressedDataStream
- All Implemented Interfaces:
- HDFSWriter
public class HDFSCompressedDataStream
- extends Object
- implements HDFSWriter
Methods inherited from class java.lang.Object |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
HDFSCompressedDataStream
public HDFSCompressedDataStream()
open
public void open(String filePath,
FlumeFormatter fmt)
throws IOException
- Specified by:
open
in interface HDFSWriter
- Throws:
IOException
open
public void open(String filePath,
CompressionCodec codec,
CompressionType cType,
FlumeFormatter fmt)
throws IOException
- Specified by:
open
in interface HDFSWriter
- Throws:
IOException
append
public void append(Event e,
FlumeFormatter fmt)
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.