public class ContainerLocalizer extends Object
Modifier and Type | Field and Description |
---|---|
static String |
APPCACHE |
static String |
FILECACHE |
static String |
OUTPUTDIR |
static String |
TOKEN_FILE_NAME_FMT |
static String |
USERCACHE |
static String |
WORKDIR |
Constructor and Description |
---|
ContainerLocalizer(org.apache.hadoop.fs.FileContext lfs,
String user,
String appId,
String localizerId,
List<org.apache.hadoop.fs.Path> localDirs,
org.apache.hadoop.yarn.factories.RecordFactory recordFactory,
org.apache.hadoop.conf.Configuration conf) |
Modifier and Type | Method and Description |
---|---|
protected void |
closeFileSystems(org.apache.hadoop.security.UserGroupInformation ugi) |
protected void |
localizeFiles(LocalizationProtocol nodemanager,
CompletionService<org.apache.hadoop.fs.Path> cs,
org.apache.hadoop.security.UserGroupInformation ugi) |
static void |
main(String[] argv) |
int |
runLocalization(InetSocketAddress nmAddr) |
public static final String FILECACHE
public static final String APPCACHE
public static final String USERCACHE
public static final String OUTPUTDIR
public static final String TOKEN_FILE_NAME_FMT
public static final String WORKDIR
public ContainerLocalizer(org.apache.hadoop.fs.FileContext lfs, String user, String appId, String localizerId, List<org.apache.hadoop.fs.Path> localDirs, org.apache.hadoop.yarn.factories.RecordFactory recordFactory, org.apache.hadoop.conf.Configuration conf) throws IOException
IOException
public int runLocalization(InetSocketAddress nmAddr) throws IOException, InterruptedException
IOException
InterruptedException
protected void closeFileSystems(org.apache.hadoop.security.UserGroupInformation ugi)
protected void localizeFiles(LocalizationProtocol nodemanager, CompletionService<org.apache.hadoop.fs.Path> cs, org.apache.hadoop.security.UserGroupInformation ugi) throws IOException
IOException
Copyright © 2015 Apache Software Foundation. All Rights Reserved.