@InterfaceAudience.Private public final class PrefetchExecutor extends Object
| Modifier and Type | Field and Description | 
|---|---|
| private static org.slf4j.Logger | LOG | 
| private static int | prefetchDelayMillisDelay before beginning prefetch | 
| private static float | prefetchDelayVariationVariation in prefetch delay times, to mitigate stampedes | 
| private static ScheduledExecutorService | prefetchExecutorPoolExecutor pool shared among all HFiles for block prefetch | 
| private static Map<org.apache.hadoop.fs.Path,Future<?>> | prefetchFuturesFutures 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–2021 The Apache Software Foundation. All rights reserved.