org.apache.flume.sink.hdfs
Class BucketWriter

java.lang.Object
  extended by org.apache.flume.sink.hdfs.BucketWriter

public class BucketWriter
extends Object


Nested Class Summary
static class BucketWriter.BucketFlushStatus
           
 
Constructor Summary
BucketWriter(long rollInt, long rollSz, long rollCnt, long bSize)
           
 
Method Summary
 void abort()
           
 BucketWriter.BucketFlushStatus append(Event e)
           
 void close()
           
 void flush()
           
 String getFilePath()
           
 void open()
           
 void open(String fPath, CompressionCodec codec, CompressionType cType, HDFSWriter hWriter, FlumeFormatter fmt)
           
 void open(String fPath, HDFSWriter hWriter, FlumeFormatter fmt)
           
 boolean shouldRotate()
           
 BucketWriter.BucketFlushStatus sync()
           
 
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
 

Constructor Detail

BucketWriter

public BucketWriter(long rollInt,
                    long rollSz,
                    long rollCnt,
                    long bSize)
             throws IOException
Throws:
IOException
Method Detail

open

public void open()
          throws IOException
Throws:
IOException

open

public void open(String fPath,
                 HDFSWriter hWriter,
                 FlumeFormatter fmt)
          throws IOException
Throws:
IOException

open

public void open(String fPath,
                 CompressionCodec codec,
                 CompressionType cType,
                 HDFSWriter hWriter,
                 FlumeFormatter fmt)
          throws IOException
Throws:
IOException

close

public void close()
           throws IOException
Throws:
IOException

abort

public void abort()

flush

public void flush()
           throws IOException
Throws:
IOException

sync

public BucketWriter.BucketFlushStatus sync()
                                    throws IOException
Throws:
IOException

append

public BucketWriter.BucketFlushStatus append(Event e)
                                      throws IOException
Throws:
IOException

shouldRotate

public boolean shouldRotate()

getFilePath

public String getFilePath()


Copyright © 2009-2012 Apache Software Foundation. All Rights Reserved.