public class DefaultResourceLocalizer extends AbstractResourceLocalizer implements SmartResourceLocalizer
LocalResource エントリに正しいパラメーターを準備することのみ可能な ResourceLocalizer のデフォルト実装。| コンストラクターと説明 |
|---|
DefaultResourceLocalizer(org.apache.hadoop.conf.Configuration configuration, java.util.Collection<LocalResourcesFactoryBean.TransferEntry> transferEntries, java.util.Collection<LocalResourcesFactoryBean.CopyEntry> copyEntries) 新しいデフォルトのリソースローカライザーをインスタンス化します。 |
DefaultResourceLocalizer(org.apache.hadoop.conf.Configuration configuration, java.util.Collection<LocalResourcesFactoryBean.TransferEntry> transferEntries, java.util.Collection<LocalResourcesFactoryBean.CopyEntry> copyEntries, org.apache.hadoop.fs.Path stagingDirectory) 新しいデフォルトのリソースローカライザーをインスタンス化します。 |
| 修飾子と型 | メソッドと説明 |
|---|---|
boolean | AddRawContent(java.lang.String key, byte[] value) 書き込むエントリにコンテンツを追加します。 |
protected void | doFileCopy(org.apache.hadoop.fs.FileSystem fs) ファイルのコピーを実行します。 |
protected java.util.Map<java.lang.String,org.apache.hadoop.yarn.api.records.LocalResource> | doFileTransfer(org.apache.hadoop.fs.FileSystem fs) ファイル転送を行います。 |
void | setRawFileContents(java.util.Map<java.lang.String,byte[]> rawFileContents) 生のファイルの内容を設定します。 |
clean, copy, deleteStagingEntries, distribute, getConfiguration, getLock, getResources, isCopied, isDistributed, resolve, resolveStagingDirectory, setCopied, setDistributed, setStagingDirectory, setStagingIdclone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, waitclean, copy, distribute, resolve, setStagingDirectory, setStagingIdgetResourcespublic DefaultResourceLocalizer(org.apache.hadoop.conf.Configuration configuration,
java.util.Collection<LocalResourcesFactoryBean.TransferEntry> transferEntries,
java.util.Collection<LocalResourcesFactoryBean.CopyEntry> copyEntries)configuration - 構成 transferEntries - 転送エントリ copyEntries - コピーエントリ public DefaultResourceLocalizer(org.apache.hadoop.conf.Configuration configuration,
java.util.Collection<LocalResourcesFactoryBean.TransferEntry> transferEntries,
java.util.Collection<LocalResourcesFactoryBean.CopyEntry> copyEntries,
org.apache.hadoop.fs.Path stagingDirectory)configuration - 構成 transferEntries - 転送エントリ copyEntries - コピーエントリ stagingDirectory - ステージングディレクトリ public boolean AddRawContent(java.lang.String key,
byte[] value)key - ファイル名として扱われるキー value - 書き込むファイルの内容 public void setRawFileContents(java.util.Map<java.lang.String,byte[]> rawFileContents)
rawFileContents - 生のファイルの内容 protected void doFileCopy(org.apache.hadoop.fs.FileSystem fs)
throws java.lang.ExceptionAbstractResourceLocalizerAbstractResourceLocalizer の doFileCopy fs - FSjava.lang.Exception - 例外 protected java.util.Map<java.lang.String,org.apache.hadoop.yarn.api.records.LocalResource> doFileTransfer(org.apache.hadoop.fs.FileSystem fs)
throws java.lang.ExceptionAbstractResourceLocalizerAbstractResourceLocalizer の doFileTransfer fs - FSjava.lang.Exception - 例外