public class HdfsInputStream extends Object implements Closeable
Modifier | Constructor and Description |
---|---|
protected |
HdfsInputStream() |
Modifier and Type | Method and Description |
---|---|
void |
close() |
static HdfsInputStream |
createInputStream(String hdfsPath,
HdfsConfiguration configuration) |
String |
getActualPath() |
int |
getChunkSize() |
Closeable |
getIn() |
long |
getNumOfReadBytes() |
long |
getNumOfReadMessages() |
boolean |
isOpened() |
long |
next(Holder<Object> key,
Holder<Object> value) |
public static HdfsInputStream createInputStream(String hdfsPath, HdfsConfiguration configuration) throws IOException
IOException
public final void close() throws IOException
close
in interface Closeable
close
in interface AutoCloseable
IOException
public final long getNumOfReadBytes()
public final long getNumOfReadMessages()
public final String getActualPath()
public final int getChunkSize()
public final Closeable getIn()
public boolean isOpened()
Apache Camel