org.apache.druid.inputsource.hdfs

Class HdfsInputEntity

java.lang.Object

org.apache.druid.data.input.RetryingInputEntity

org.apache.druid.inputsource.hdfs.HdfsInputEntity

All Implemented Interfaces:

InputEntity

public class HdfsInputEntity
extends RetryingInputEntity

Nested Class Summary

Nested classes/interfaces inherited from interface org.apache.druid.data.input.InputEntity

InputEntity.CleanableFile

Field Summary

Fields inherited from interface org.apache.druid.data.input.InputEntity

DEFAULT_FETCH_BUFFER_SIZE, DEFAULT_MAX_NUM_FETCH_TRIES, LOG

Method Summary

Modifier and Type	Method and Description
protected String	getPath()
com.google.common.base.Predicate<Throwable>	getRetryCondition()
URI	getUri()
protected InputStream	readFrom(long offset)

Methods inherited from class org.apache.druid.data.input.RetryingInputEntity

open, readFromStart

Methods inherited from class java.lang.Object

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

Methods inherited from interface org.apache.druid.data.input.InputEntity

fetch

Method Detail

getUri

public URI getUri()

readFrom

protected InputStream readFrom(long offset)
                        throws IOException

Specified by:

readFrom in class RetryingInputEntity

Throws:

IOException

getPath

protected String getPath()

Specified by:

getPath in class RetryingInputEntity

getRetryCondition

public com.google.common.base.Predicate<Throwable> getRetryCondition()