@InterfaceAudience.Private public final class PrefetchExecutor extends Object
Modifier and Type | Field and Description |
---|---|
private static org.slf4j.Logger |
LOG |
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 Random |
RNG |
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) |
static boolean |
isCompleted(org.apache.hadoop.fs.Path path) |
static void |
request(org.apache.hadoop.fs.Path path,
Runnable runnable) |
private static final org.slf4j.Logger LOG
private static final Map<org.apache.hadoop.fs.Path,Future<?>> prefetchFutures
private static final ScheduledExecutorService prefetchExecutorPool
private static final int prefetchDelayMillis
private static final 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 boolean isCompleted(org.apache.hadoop.fs.Path path)
Copyright © 2007–2019 The Apache Software Foundation. All rights reserved.