| Package | Description |
|---|---|
| org.apache.druid.firehose.hdfs | |
| org.apache.druid.inputsource.hdfs | |
| org.apache.druid.storage.hdfs | |
| org.apache.druid.storage.hdfs.tasklog |
| Constructor and Description |
|---|
HdfsFirehoseFactory(org.apache.hadoop.conf.Configuration conf,
Object inputPaths,
Long maxCacheCapacityBytes,
Long maxFetchCapacityBytes,
Long prefetchTriggerBytes,
Long fetchTimeout,
Integer maxFetchRetry) |
| Constructor and Description |
|---|
HdfsInputSource(Object inputPaths,
org.apache.hadoop.conf.Configuration configuration) |
| Constructor and Description |
|---|
HdfsDataSegmentKiller(org.apache.hadoop.conf.Configuration config,
HdfsDataSegmentPusherConfig pusherConfig) |
HdfsDataSegmentPuller(org.apache.hadoop.conf.Configuration config) |
HdfsDataSegmentPusher(HdfsDataSegmentPusherConfig config,
org.apache.hadoop.conf.Configuration hadoopConfig,
com.fasterxml.jackson.databind.ObjectMapper jsonMapper) |
HdfsFileTimestampVersionFinder(org.apache.hadoop.conf.Configuration config) |
HdfsStorageAuthentication(HdfsKerberosConfig hdfsKerberosConfig,
org.apache.hadoop.conf.Configuration hadoopConf) |
| Constructor and Description |
|---|
HdfsTaskLogs(HdfsTaskLogsConfig config,
org.apache.hadoop.conf.Configuration hadoopConfig) |
Copyright © 2011–2021 The Apache Software Foundation. All rights reserved.