public class JobFactoryBean
extends java.lang.Object
implements org.springframework.beans.factory.InitializingBean, org.springframework.beans.factory.FactoryBean<org.apache.hadoop.mapreduce.Job>, org.springframework.beans.factory.BeanNameAware, org.springframework.beans.factory.BeanClassLoaderAwaresetJar(Resource)) で使用できない jar 上にある場合に意図的に行われます。その場合、特別なオンザフライクラスローダーが使用されます。| コンストラクターと説明 |
|---|
JobFactoryBean() |
| 修飾子と型 | メソッドと説明 |
|---|---|
void | afterPropertiesSet() |
org.apache.hadoop.mapreduce.Job | getObject() |
java.lang.Class<?> | getObjectType() |
boolean | isSingleton() |
protected void | processJob(org.apache.hadoop.mapreduce.Job job) |
void | setArchives(org.springframework.core.io.Resource... archives) マップ削減クラスターにアーカイブ解除するアーカイブを設定します。 |
void | setBeanClassLoader(java.lang.ClassLoader classLoader) |
void | setBeanName(java.lang.String name) |
void | setCodec(java.lang.String codecClass) ジョブコーデッククラスを設定します。 |
void | setCombiner(java.lang.String combiner) ジョブコンバイナクラスを設定します。 |
void | setCompressOutput(java.lang.Boolean compressOutput) ジョブ出力を圧縮するかどうかを示します。 |
void | setConfiguration(org.apache.hadoop.conf.Configuration configuration) 使用する Hadoop 構成を設定します。 |
void | setFiles(org.springframework.core.io.Resource... files) マップ削減クラスターにコピーするファイルを設定します。 |
void | setGroupingComparator(java.lang.String groupingComparator) ジョブグループ化比較クラスを設定します。 |
void | setInputFormat(java.lang.String inputFormat) ジョブ入力形式クラスを設定します。 |
void | setInputPath(java.lang.String... inputPath) ジョブ入力パスを設定します。 |
void | setJar(org.springframework.core.io.Resource jar) ジョブ jar を設定します (クラスパス上にない可能性があります)。 |
void | setJarByClass(java.lang.Class<?> jarClass) 指定されたクラスに基づいてジョブ jar (クラスパスで使用可能) を決定します。 |
void | setKey(java.lang.String key) ジョブキークラスを設定します。 |
void | setLibs(org.springframework.core.io.Resource... libJars) クラスパスに含める jar ファイルを設定します。 |
void | setMapKey(java.lang.String mapKey) ジョブマップキークラスを設定します。 |
void | setMapper(java.lang.String mapper) ジョブマッパークラスを設定します。 |
void | setMapValue(java.lang.String mapValue) ジョブマップ値クラスを設定します。 |
void | setName(java.lang.String name) ジョブ名を設定します。 |
void | setNumberReducers(java.lang.Integer numReduceTasks) このジョブの削減タスクの数を設定します。 |
void | setOutputFormat(java.lang.String outputFormat) ジョブ出力形式クラスを設定します。 |
void | setOutputPath(java.lang.String outputPath) ジョブ出力パスを設定します。 |
void | setPartitioner(java.lang.String partitioner) ジョブパーティショナークラスを設定します。 |
void | setProperties(java.util.Properties properties) このジョブに設定する構成プロパティ。 |
void | setReducer(java.lang.String reducer) ジョブリデューサークラスを設定します。 |
void | setSortComparator(java.lang.String sortComparator) ジョブソート比較クラスを設定します。 |
void | setUser(java.lang.String user) このジョブを実行するためのユーザーの偽装 (オプション) を設定します。 |
void | setValue(java.lang.String value) ジョブ値クラスを設定します。 |
void | setWorkingDir(java.lang.String workingDir) ジョブの作業ディレクトリを設定します。 |
public void setBeanClassLoader(java.lang.ClassLoader classLoader)
org.springframework.beans.factory.BeanClassLoaderAware 内の setBeanClassLoader public void setBeanName(java.lang.String name)
org.springframework.beans.factory.BeanNameAware 内の setBeanName public org.apache.hadoop.mapreduce.Job getObject()
throws java.lang.Exceptionorg.springframework.beans.factory.FactoryBean<org.apache.hadoop.mapreduce.Job> 内の getObject java.lang.Exceptionpublic java.lang.Class<?> getObjectType()
org.springframework.beans.factory.FactoryBean<org.apache.hadoop.mapreduce.Job> 内の getObjectType public boolean isSingleton()
org.springframework.beans.factory.FactoryBean<org.apache.hadoop.mapreduce.Job> 内の isSingleton public void afterPropertiesSet()
throws java.lang.Exceptionorg.springframework.beans.factory.InitializingBean 内の afterPropertiesSet java.lang.Exceptionprotected void processJob(org.apache.hadoop.mapreduce.Job job)
throws java.lang.Exceptionjava.lang.Exceptionpublic void setConfiguration(org.apache.hadoop.conf.Configuration configuration)
configuration - 設定する構成。public void setName(java.lang.String name)
name - 設定する名前。public void setKey(java.lang.String key)
key - 設定する keyClass。public void setValue(java.lang.String value)
value - 設定する valueClass。public void setMapKey(java.lang.String mapKey)
mapKey - 設定する mapKeyClass。public void setMapValue(java.lang.String mapValue)
mapValue - 設定する mapValueClass。public void setMapper(java.lang.String mapper)
mapper - 設定するマッパー。public void setReducer(java.lang.String reducer)
reducer - 設定するリデューサー。public void setCombiner(java.lang.String combiner)
combiner - 設定するコンバイナ。public void setInputFormat(java.lang.String inputFormat)
inputFormat - 設定する inputFormat。public void setOutputFormat(java.lang.String outputFormat)
outputFormat - 設定する outputFormat。public void setPartitioner(java.lang.String partitioner)
partitioner - 設定するパーティショナー。public void setSortComparator(java.lang.String sortComparator)
sortComparator - 設定する sortComparator。public void setGroupingComparator(java.lang.String groupingComparator)
groupingComparator - 設定する groupingComparator。public void setWorkingDir(java.lang.String workingDir)
workingDir - 設定する workingDir。public void setNumberReducers(java.lang.Integer numReduceTasks)
numReduceTasks - 設定する numReduceTasks。public void setJarByClass(java.lang.Class<?> jarClass)
jarClass - 設定する jarClass。public void setJar(org.springframework.core.io.Resource jar)
jar - 設定する jar。public void setInputPath(java.lang.String... inputPath)
inputPath - ジョブ入力パス。public void setOutputPath(java.lang.String outputPath)
outputPath - 設定する outputPath。public void setCompressOutput(java.lang.Boolean compressOutput)
compressOutput - 設定する compressOutput。public void setCodec(java.lang.String codecClass)
codecClass - 設定する codecClass。public void setProperties(java.util.Properties properties)
properties - 設定するプロパティ。public void setLibs(org.springframework.core.io.Resource... libJars)
mydir/*.jar) を使用できることに注意してください。これは、Spring コンテナーによって自動的に解決されます。libJars - クラスパスに含める jar ファイル。public void setFiles(org.springframework.core.io.Resource... files)
mydir/*.txt) を使用できることに注意してください。これは、Spring コンテナーによって自動的に解決されます。files - コピーするファイル。public void setArchives(org.springframework.core.io.Resource... archives)
mydir/*.zip) を使用できることに注意してください。これは、Spring コンテナーによって自動的に解決されます。archives - コンピューティングマシン上でアーカイブ解除するアーカイブ。public void setUser(java.lang.String user)
user - ユーザー / グループ情報