public class ContainerLocalizer extends Object
Modifier and Type | Field and Description |
---|---|
static String |
APPCACHE |
static String |
CSI_VOLIUME_MOUNTS_ROOT |
static String |
FILECACHE |
static String |
USERCACHE |
Constructor and Description |
---|
ContainerLocalizer(org.apache.hadoop.fs.FileContext lfs,
String user,
String appId,
String localizerId,
String tokenFileName,
List<org.apache.hadoop.fs.Path> localDirs,
org.apache.hadoop.yarn.factories.RecordFactory recordFactory) |
Modifier and Type | Method and Description |
---|---|
static void |
buildMainArgs(List<String> command,
String user,
String appId,
String locId,
InetSocketAddress nmAddr,
String tokenFileName,
List<String> localDirs,
org.apache.hadoop.conf.Configuration conf)
Adds the ContainerLocalizer arguments for a @{link ShellCommandExecutor},
as expected by ContainerLocalizer.main
|
protected void |
closeFileSystems(org.apache.hadoop.security.UserGroupInformation ugi) |
static List<String> |
getJavaOpts(org.apache.hadoop.conf.Configuration conf)
Returns the JVM options to to launch the resource localizer.
|
LocalizationProtocol |
getProxy(InetSocketAddress nmAddr) |
protected void |
localizeFiles(LocalizationProtocol nodemanager,
CompletionService<org.apache.hadoop.fs.Path> cs,
org.apache.hadoop.security.UserGroupInformation ugi) |
static void |
main(String[] argv) |
void |
runLocalization(InetSocketAddress nmAddr) |
public static final String FILECACHE
public static final String APPCACHE
public static final String USERCACHE
public static final String CSI_VOLIUME_MOUNTS_ROOT
public ContainerLocalizer(org.apache.hadoop.fs.FileContext lfs, String user, String appId, String localizerId, String tokenFileName, List<org.apache.hadoop.fs.Path> localDirs, org.apache.hadoop.yarn.factories.RecordFactory recordFactory) throws IOException
IOException
@InterfaceAudience.Private public LocalizationProtocol getProxy(InetSocketAddress nmAddr)
public void 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, org.apache.hadoop.yarn.exceptions.YarnException
IOException
org.apache.hadoop.yarn.exceptions.YarnException
public static List<String> getJavaOpts(org.apache.hadoop.conf.Configuration conf)
conf
- the configuration properties to launch the resource localizer.public static void buildMainArgs(List<String> command, String user, String appId, String locId, InetSocketAddress nmAddr, String tokenFileName, List<String> localDirs, org.apache.hadoop.conf.Configuration conf)
command
- the current ShellCommandExecutor command lineuser
- localization userappId
- localized app idlocId
- localizer idnmAddr
- nodemanager addresslocalDirs
- list of local dirsCopyright © 2008–2023 Apache Software Foundation. All rights reserved.