org.apache.camel.component.hdfs
Class HdfsInputStream

java.lang.Object
  org.apache.camel.component.hdfs.HdfsInputStream

All Implemented Interfaces:

Closeable

public class HdfsInputStream
extends Object
implements Closeable

Constructor Summary

protected

HdfsInputStream()

Method Summary

void	close()
static HdfsInputStream	createInputStream(String hdfsPath, HdfsConfiguration configuration)
String	getActualPath()
int	getChunkSize()
Closeable	getIn()
long	getNumOfReadBytes()
long	getNumOfReadMessages()
long	next(Holder<Object> key, Holder<Object> value)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

HdfsInputStream

protected HdfsInputStream()

Method Detail

createInputStream

public static HdfsInputStream createInputStream(String hdfsPath,
                                                HdfsConfiguration configuration)
                                         throws IOException

Throws:

IOException

close

public final void close()
                 throws IOException

Specified by:

close in interface Closeable

Throws:

IOException

next

public final long next(Holder<Object> key,
                       Holder<Object> value)

getNumOfReadBytes

public final long getNumOfReadBytes()

getNumOfReadMessages

public final long getNumOfReadMessages()

getActualPath

public final String getActualPath()

getChunkSize

public final int getChunkSize()

getIn

public final Closeable getIn()