A B C D E F G H I K L M N O P R S T W

A

authenticate() - Method in class org.apache.druid.storage.hdfs.HdfsStorageAuthentication

Dose authenticate against a secured hadoop cluster In case of any bug fix make sure to fix the code in JobHelper#authenticate as well.

B

buildFileObject(URI, Configuration) - Static method in class org.apache.druid.storage.hdfs.HdfsDataSegmentPuller

buildFileObject(URI, Configuration, Boolean) - Static method in class org.apache.druid.storage.hdfs.HdfsDataSegmentPuller

C

coerceInputPathsToList(Object, String) - Static method in class org.apache.druid.inputsource.hdfs.HdfsInputSource

config - Variable in class org.apache.druid.storage.hdfs.HdfsDataSegmentPuller

configure(Binder) - Method in class org.apache.druid.storage.hdfs.HdfsStorageDruidModule

createSplits(InputFormat, SplitHintSpec) - Method in class org.apache.druid.inputsource.hdfs.HdfsInputSource

D

DEFAULT_RETRY_COUNT - Static variable in class org.apache.druid.storage.hdfs.HdfsDataSegmentPuller

E

equals(Object) - Method in class org.apache.druid.storage.hdfs.HdfsKerberosConfig

estimateNumSplits(InputFormat, SplitHintSpec) - Method in class org.apache.druid.inputsource.hdfs.HdfsInputSource

F

formattableReader(InputRowSchema, InputFormat, File) - Method in class org.apache.druid.inputsource.hdfs.HdfsInputSource

G

getDirectory() - Method in class org.apache.druid.storage.hdfs.tasklog.HdfsTaskLogsConfig

getInputPaths() - Method in class org.apache.druid.firehose.hdfs.HdfsFirehoseFactory

getInputStream(Path) - Method in class org.apache.druid.storage.hdfs.HdfsDataSegmentPuller

getInputStream(URI) - Method in class org.apache.druid.storage.hdfs.HdfsDataSegmentPuller

getIOException() - Method in exception org.apache.druid.storage.hdfs.HdfsDataSegmentPuller.HdfsIOException

getJacksonModules() - Method in class org.apache.druid.storage.hdfs.HdfsStorageDruidModule

getKeytab() - Method in class org.apache.druid.storage.hdfs.HdfsKerberosConfig

getLatestVersion(URI, Pattern) - Method in class org.apache.druid.storage.hdfs.HdfsFileTimestampVersionFinder

Returns the latest modified file at the uri of interest.

getPath() - Method in class org.apache.druid.inputsource.hdfs.HdfsInputEntity

getPathForHadoop(String) - Method in class org.apache.druid.storage.hdfs.HdfsDataSegmentPusher

Deprecated.

getPathForHadoop() - Method in class org.apache.druid.storage.hdfs.HdfsDataSegmentPusher

getPaths(List<String>, Configuration) - Static method in class org.apache.druid.inputsource.hdfs.HdfsInputSource

getPathString() - Method in class org.apache.druid.storage.hdfs.HdfsLoadSpec

getPrincipal() - Method in class org.apache.druid.storage.hdfs.HdfsKerberosConfig

getRetryCondition() - Method in class org.apache.druid.firehose.hdfs.HdfsFirehoseFactory

getRetryCondition() - Method in class org.apache.druid.inputsource.hdfs.HdfsInputEntity

getStorageDir(DataSegment, boolean) - Method in class org.apache.druid.storage.hdfs.HdfsDataSegmentPusher

Due to https://issues.apache.org/jira/browse/HDFS-13 ":" are not allowed in path names.

getStorageDirectory() - Method in class org.apache.druid.storage.hdfs.HdfsDataSegmentPusherConfig

getUri() - Method in class org.apache.druid.inputsource.hdfs.HdfsInputEntity

getVersion(URI) - Method in class org.apache.druid.storage.hdfs.HdfsDataSegmentPuller

Return the "version" (aka last modified timestamp) of the URI

H

hashCode() - Method in class org.apache.druid.storage.hdfs.HdfsKerberosConfig

Hdfs - Annotation Type in org.apache.druid.guice

Each extension module needs to properly bind whatever it will use, but sometimes different modules need to bind the same class which will lead to the duplicate injection error.

HdfsDataSegmentKiller - Class in org.apache.druid.storage.hdfs

HdfsDataSegmentKiller(Configuration, HdfsDataSegmentPusherConfig) - Constructor for class org.apache.druid.storage.hdfs.HdfsDataSegmentKiller

HdfsDataSegmentPuller - Class in org.apache.druid.storage.hdfs

HdfsDataSegmentPuller(Configuration) - Constructor for class org.apache.druid.storage.hdfs.HdfsDataSegmentPuller

HdfsDataSegmentPuller.HdfsIOException - Exception in org.apache.druid.storage.hdfs

FileObject.getLastModified and FileObject.delete don't throw IOException.

HdfsDataSegmentPusher - Class in org.apache.druid.storage.hdfs

HdfsDataSegmentPusher(HdfsDataSegmentPusherConfig, Configuration, ObjectMapper) - Constructor for class org.apache.druid.storage.hdfs.HdfsDataSegmentPusher

HdfsDataSegmentPusherConfig - Class in org.apache.druid.storage.hdfs

HdfsDataSegmentPusherConfig() - Constructor for class org.apache.druid.storage.hdfs.HdfsDataSegmentPusherConfig

HdfsFileTimestampVersionFinder - Class in org.apache.druid.storage.hdfs

HdfsFileTimestampVersionFinder(Configuration) - Constructor for class org.apache.druid.storage.hdfs.HdfsFileTimestampVersionFinder

HdfsFirehoseFactory - Class in org.apache.druid.firehose.hdfs

HdfsFirehoseFactory(Configuration, Object, Long, Long, Long, Long, Integer) - Constructor for class org.apache.druid.firehose.hdfs.HdfsFirehoseFactory

HdfsInputEntity - Class in org.apache.druid.inputsource.hdfs

HdfsInputSource - Class in org.apache.druid.inputsource.hdfs

HdfsInputSource(Object, Configuration) - Constructor for class org.apache.druid.inputsource.hdfs.HdfsInputSource

HdfsIOException(IOException) - Constructor for exception org.apache.druid.storage.hdfs.HdfsDataSegmentPuller.HdfsIOException

HdfsKerberosConfig - Class in org.apache.druid.storage.hdfs

HdfsKerberosConfig(String, String) - Constructor for class org.apache.druid.storage.hdfs.HdfsKerberosConfig

HdfsLoadSpec - Class in org.apache.druid.storage.hdfs

HdfsLoadSpec(HdfsDataSegmentPuller, String) - Constructor for class org.apache.druid.storage.hdfs.HdfsLoadSpec

HdfsStorageAuthentication - Class in org.apache.druid.storage.hdfs

HdfsStorageAuthentication(HdfsKerberosConfig, Configuration) - Constructor for class org.apache.druid.storage.hdfs.HdfsStorageAuthentication

HdfsStorageDruidModule - Class in org.apache.druid.storage.hdfs

HdfsStorageDruidModule() - Constructor for class org.apache.druid.storage.hdfs.HdfsStorageDruidModule

HdfsTaskLogs - Class in org.apache.druid.storage.hdfs.tasklog

Indexer hdfs task logs, to support storing hdfs tasks to hdfs.

HdfsTaskLogs(HdfsTaskLogsConfig, Configuration) - Constructor for class org.apache.druid.storage.hdfs.tasklog.HdfsTaskLogs

HdfsTaskLogsConfig - Class in org.apache.druid.storage.hdfs.tasklog

Indexer hdfs task logs configuration.

HdfsTaskLogsConfig(String) - Constructor for class org.apache.druid.storage.hdfs.tasklog.HdfsTaskLogsConfig

I

initObjects() - Method in class org.apache.druid.firehose.hdfs.HdfsFirehoseFactory

isSplittable() - Method in class org.apache.druid.firehose.hdfs.HdfsFirehoseFactory

K

kill(DataSegment) - Method in class org.apache.druid.storage.hdfs.HdfsDataSegmentKiller

killAll() - Method in class org.apache.druid.storage.hdfs.HdfsDataSegmentKiller

killAll() - Method in class org.apache.druid.storage.hdfs.tasklog.HdfsTaskLogs

killOlderThan(long) - Method in class org.apache.druid.storage.hdfs.tasklog.HdfsTaskLogs

L

loadSegment(File) - Method in class org.apache.druid.storage.hdfs.HdfsLoadSpec

M

makeIndexPathName(DataSegment, String) - Method in class org.apache.druid.storage.hdfs.HdfsDataSegmentPusher

makeLoadSpec(URI) - Method in class org.apache.druid.storage.hdfs.HdfsDataSegmentPusher

N

needsFormat() - Method in class org.apache.druid.inputsource.hdfs.HdfsInputSource

O

openObjectStream(Path) - Method in class org.apache.druid.firehose.hdfs.HdfsFirehoseFactory

openObjectStream(Path, long) - Method in class org.apache.druid.firehose.hdfs.HdfsFirehoseFactory

org.apache.druid.firehose.hdfs - package org.apache.druid.firehose.hdfs

org.apache.druid.guice - package org.apache.druid.guice

org.apache.druid.inputsource.hdfs - package org.apache.druid.inputsource.hdfs

org.apache.druid.storage.hdfs - package org.apache.druid.storage.hdfs

org.apache.druid.storage.hdfs.tasklog - package org.apache.druid.storage.hdfs.tasklog

P

push(File, DataSegment, boolean) - Method in class org.apache.druid.storage.hdfs.HdfsDataSegmentPusher

pushTaskLog(String, File) - Method in class org.apache.druid.storage.hdfs.tasklog.HdfsTaskLogs

pushTaskReports(String, File) - Method in class org.apache.druid.storage.hdfs.tasklog.HdfsTaskLogs

R

readFrom(long) - Method in class org.apache.druid.inputsource.hdfs.HdfsInputEntity

RETRY_PREDICATE - Static variable in class org.apache.druid.storage.hdfs.HdfsDataSegmentPuller

S

setProperties(Properties) - Method in class org.apache.druid.storage.hdfs.HdfsStorageDruidModule

setStorageDirectory(String) - Method in class org.apache.druid.storage.hdfs.HdfsDataSegmentPusherConfig

shouldRetryPredicate() - Method in class org.apache.druid.storage.hdfs.HdfsDataSegmentPuller

stop() - Method in class org.apache.druid.storage.hdfs.HdfsStorageAuthentication

streamTaskLog(String, long) - Method in class org.apache.druid.storage.hdfs.tasklog.HdfsTaskLogs

streamTaskReports(String) - Method in class org.apache.druid.storage.hdfs.tasklog.HdfsTaskLogs

T

toString() - Method in class org.apache.druid.firehose.hdfs.HdfsFirehoseFactory

W

withSplit(InputSplit<Path>) - Method in class org.apache.druid.firehose.hdfs.HdfsFirehoseFactory

withSplit(InputSplit<List<Path>>) - Method in class org.apache.druid.inputsource.hdfs.HdfsInputSource

wrapObjectStream(Path, InputStream) - Method in class org.apache.druid.firehose.hdfs.HdfsFirehoseFactory

A B C D E F G H I K L M N O P R S T W