A B C D E F G H K L M O P S

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

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

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

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

F

findSegments(String, boolean) - Method in class org.apache.druid.storage.hdfs.HdfsDataSegmentFinder

G

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

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.

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

Deprecated.

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

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

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

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

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

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

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

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

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

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

O

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

S

SCHEME - Static variable in class org.apache.druid.storage.hdfs.HdfsStorageDruidModule

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

A B C D E F G H K L M O P S