org.apache.flume.sink.hdfs
Class HDFSSequenceFile

java.lang.Object
  extended by org.apache.flume.sink.hdfs.HDFSSequenceFile
All Implemented Interfaces:
HDFSWriter

public class HDFSSequenceFile
extends Object
implements HDFSWriter


Constructor Summary
HDFSSequenceFile()
           
 
Method Summary
 void append(Event e, FlumeFormatter formatter)
           
 void close()
           
 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

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.