org.apache.flume.sink.hdfs
Interface HDFSWriter

All Superinterfaces:

Configurable

All Known Implementing Classes:

HDFSCompressedDataStream, HDFSDataStream, HDFSSequenceFile

public interface HDFSWriter
extends Configurable

Method Summary

void	append(Event e, FlumeFormatter fmt)
void	close()
void	open(String filePath, org.apache.hadoop.io.compress.CompressionCodec codec, org.apache.hadoop.io.SequenceFile.CompressionType cType, FlumeFormatter fmt)
void	open(String filePath, FlumeFormatter fmt)
void	sync()

Methods inherited from interface org.apache.flume.conf.Configurable

configure

Method Detail

open

void open(String filePath,
          FlumeFormatter fmt)
          throws IOException

Throws:

IOException

open

void open(String filePath,
          org.apache.hadoop.io.compress.CompressionCodec codec,
          org.apache.hadoop.io.SequenceFile.CompressionType cType,
          FlumeFormatter fmt)
          throws IOException

Throws:

IOException

append

void append(Event e,
            FlumeFormatter fmt)
            throws IOException

Throws:

IOException

sync

void sync()
          throws IOException

Throws:

IOException

close

void close()
           throws IOException

Throws:

IOException