org.apache.flume.sink.hdfs
Class BucketWriter
java.lang.Object
org.apache.flume.sink.hdfs.BucketWriter
public class BucketWriter
- extends Object
Constructor Summary |
BucketWriter(long rollInt,
long rollSz,
long rollCnt,
long bSize)
|
Methods inherited from class java.lang.Object |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
BucketWriter
public BucketWriter(long rollInt,
long rollSz,
long rollCnt,
long bSize)
throws IOException
- Throws:
IOException
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.