org.apache.camel.component.hdfs
Class HdfsOutputStream
java.lang.Object
org.apache.camel.component.hdfs.HdfsOutputStream
- All Implemented Interfaces:
- Closeable
public class HdfsOutputStream
- extends Object
- implements Closeable
Methods inherited from class java.lang.Object |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
HdfsOutputStream
protected HdfsOutputStream()
createOutputStream
public static HdfsOutputStream createOutputStream(String hdfsPath,
HdfsConfiguration configuration)
throws IOException
- Throws:
IOException
close
public void close()
throws IOException
- Specified by:
close
in interface Closeable
- Throws:
IOException
append
public void append(Object key,
Object value,
org.apache.camel.TypeConverter typeConverter)
getNumOfWrittenBytes
public long getNumOfWrittenBytes()
getNumOfWrittenMessages
public long getNumOfWrittenMessages()
getLastAccess
public long getLastAccess()
getActualPath
public String getActualPath()
isBusy
public AtomicBoolean isBusy()
getOut
public Closeable getOut()
Apache Camel