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(FileContext lfs,
String user,
String appId,
String localizerId,
List<Path> localDirs,
RecordFactory recordFactory) |
Modifier and Type | Method and Description |
---|---|
protected void |
closeFileSystems(UserGroupInformation ugi) |
protected void |
localizeFiles(LocalizationProtocol nodemanager,
CompletionService<Path> cs,
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(FileContext lfs, String user, String appId, String localizerId, List<Path> localDirs, RecordFactory recordFactory) throws IOException
IOException
public int runLocalization(InetSocketAddress nmAddr) throws IOException, InterruptedException
IOException
InterruptedException
protected void closeFileSystems(UserGroupInformation ugi)
protected void localizeFiles(LocalizationProtocol nodemanager, CompletionService<Path> cs, UserGroupInformation ugi) throws IOException
IOException
Copyright © 2013 Apache Software Foundation. All rights reserved.