public class HdfsOutputStream extends Object implements Closeable
Modifier | Constructor and Description |
---|---|
protected |
HdfsOutputStream() |
Modifier and Type | Method and Description |
---|---|
void |
append(Object key,
Object value,
org.apache.camel.TypeConverter typeConverter) |
void |
close() |
static HdfsOutputStream |
createOutputStream(String hdfsPath,
HdfsConfiguration configuration) |
String |
getActualPath() |
long |
getLastAccess() |
long |
getNumOfWrittenBytes() |
long |
getNumOfWrittenMessages() |
Closeable |
getOut() |
AtomicBoolean |
isBusy() |
public static HdfsOutputStream createOutputStream(String hdfsPath, HdfsConfiguration configuration) throws IOException
IOException
public void close() throws IOException
close
in interface Closeable
close
in interface AutoCloseable
IOException
public long getNumOfWrittenBytes()
public long getNumOfWrittenMessages()
public long getLastAccess()
public String getActualPath()
public AtomicBoolean isBusy()
public Closeable getOut()
Apache Camel