org.apache.flume.sink.hdfs
Class HDFSSequenceFile

java.lang.Object
  org.apache.flume.sink.hdfs.HDFSSequenceFile

All Implemented Interfaces:

Configurable, HDFSWriter

public class HDFSSequenceFile
extends Object
implements HDFSWriter

Constructor Summary

HDFSSequenceFile()

Method Summary

void	append(Event e, FlumeFormatter formatter)
void	close()
void	configure(Context context) Request the implementing class to (re)configure itself.
void	open(String filePath, org.apache.hadoop.io.compress.CompressionCodec codeC, org.apache.hadoop.io.SequenceFile.CompressionType compType, FlumeFormatter fmt)
void	open(String filePath, FlumeFormatter fmt)
void	sync()

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

HDFSSequenceFile

public HDFSSequenceFile()

Method Detail

configure

public void configure(Context context)

Description copied from interface: Configurable

Request the implementing class to (re)configure itself.

When configuration parameters are changed, they must be reflected by the component asap.

There are no thread safety guarrantees on when configure might be called.

Specified by:

configure in interface Configurable

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