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)
Reads next record/chunk specific to give file type.
|
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 next(Holder<Object> key, Holder<Object> value)
key
- value
- 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