org.apache.drill.yarn.core

Class DfsFacade.Localizer

java.lang.Object

org.apache.drill.yarn.core.DfsFacade.Localizer

Enclosing class:

DfsFacade

public static class DfsFacade.Localizer
extends Object

Field Summary

Fields

Modifier and Type	Field and Description
protected org.apache.hadoop.fs.Path	dfsArchivePath
protected File	localArchivePath

Constructor Summary

Constructors

Constructor and Description
Localizer(DfsFacade dfs, File archivePath, org.apache.hadoop.fs.Path destPath, String label)
Localizer(DfsFacade dfs, File archivePath, String label) Resources to be localized (downloaded) to each AM or drillbit node.
Localizer(DfsFacade dfs, File archivePath, String destName, String label)
Localizer(DfsFacade dfs, String destPath)

Method Summary

Modifier and Type	Method and Description
void	defineResources(Map<String,org.apache.hadoop.yarn.api.records.LocalResource> resources, String key)
boolean	destExists()
boolean	filesMatch()
String	getBaseName()
String	getDestPath()
String	getLabel()
void	upload()

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Field Detail

localArchivePath

protected File localArchivePath

dfsArchivePath

protected org.apache.hadoop.fs.Path dfsArchivePath

Constructor Detail

Localizer

public Localizer(DfsFacade dfs,
                 File archivePath,
                 String label)

Resources to be localized (downloaded) to each AM or drillbit node.

Localizer

public Localizer(DfsFacade dfs,
                 File archivePath,
                 String destName,
                 String label)

Localizer

public Localizer(DfsFacade dfs,
                 String destPath)

Localizer

public Localizer(DfsFacade dfs,
                 File archivePath,
                 org.apache.hadoop.fs.Path destPath,
                 String label)

Method Detail

getBaseName

public String getBaseName()

getDestPath

public String getDestPath()

upload

public void upload()
            throws DfsFacade.DfsFacadeException

Throws:

DfsFacade.DfsFacadeException

defineResources

public void defineResources(Map<String,org.apache.hadoop.yarn.api.records.LocalResource> resources,
                            String key)
                     throws DfsFacade.DfsFacadeException

Throws:

DfsFacade.DfsFacadeException

filesMatch

public boolean filesMatch()

getLabel

public String getLabel()

destExists

public boolean destExists()
                   throws IOException

Throws:

IOException