@InterfaceAudience.Private public final class PrefetchExecutor extends Object
Modifier and Type | Field and Description |
---|---|
private static org.slf4j.Logger |
LOG |
static String |
PREFETCH_DELAY
Wait time in miliseconds before executing prefetch
|
static String |
PREFETCH_DELAY_VARIATION |
static float |
PREFETCH_DELAY_VARIATION_DEFAULT_VALUE |
private static int |
prefetchDelayMillis
Delay before beginning prefetch
|
private static float |
prefetchDelayVariation
Variation in prefetch delay times, to mitigate stampedes
|
private static ScheduledExecutorService |
prefetchExecutorPool
Executor pool shared among all HFiles for block prefetch
|
private static Map<org.apache.hadoop.fs.Path,Future<?>> |
prefetchFutures
Futures for tracking block prefetch activity
|
private static Pattern |
prefetchPathExclude |
private static Map<org.apache.hadoop.fs.Path,Runnable> |
prefetchRunnable
Runnables for resetting the prefetch activity
|
Modifier | Constructor and Description |
---|---|
private |
PrefetchExecutor() |
Modifier and Type | Method and Description |
---|---|
static void |
cancel(org.apache.hadoop.fs.Path path) |
static void |
complete(org.apache.hadoop.fs.Path path) |
(package private) static ScheduledExecutorService |
getExecutorPool() |
static int |
getPrefetchDelay() |
(package private) static Map<org.apache.hadoop.fs.Path,Future<?>> |
getPrefetchFutures() |
(package private) static Map<org.apache.hadoop.fs.Path,Runnable> |
getPrefetchRunnable() |
static void |
interrupt(org.apache.hadoop.fs.Path path) |
static boolean |
isCompleted(org.apache.hadoop.fs.Path path) |
(package private) static boolean |
isPrefetchStarted() |
static void |
loadConfiguration(org.apache.hadoop.conf.Configuration conf) |
static void |
request(org.apache.hadoop.fs.Path path,
Runnable runnable) |
private static final org.slf4j.Logger LOG
public static final String PREFETCH_DELAY
public static final String PREFETCH_DELAY_VARIATION
public static final float PREFETCH_DELAY_VARIATION_DEFAULT_VALUE
private static final Map<org.apache.hadoop.fs.Path,Future<?>> prefetchFutures
private static final Map<org.apache.hadoop.fs.Path,Runnable> prefetchRunnable
private static final ScheduledExecutorService prefetchExecutorPool
private static int prefetchDelayMillis
private static float prefetchDelayVariation
private static final Pattern prefetchPathExclude
private PrefetchExecutor()
public static void complete(org.apache.hadoop.fs.Path path)
public static void cancel(org.apache.hadoop.fs.Path path)
public static void interrupt(org.apache.hadoop.fs.Path path)
public static boolean isCompleted(org.apache.hadoop.fs.Path path)
static ScheduledExecutorService getExecutorPool()
static Map<org.apache.hadoop.fs.Path,Future<?>> getPrefetchFutures()
static Map<org.apache.hadoop.fs.Path,Runnable> getPrefetchRunnable()
static boolean isPrefetchStarted()
public static int getPrefetchDelay()
public static void loadConfiguration(org.apache.hadoop.conf.Configuration conf)
Copyright © 2007–2020 The Apache Software Foundation. All rights reserved.