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.BeanClassLoaderAware
setJar(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.Exception
org.springframework.beans.factory.FactoryBean<org.apache.hadoop.mapreduce.Job>
の getObject
java.lang.Exception
public 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.Exception
org.springframework.beans.factory.InitializingBean
の afterPropertiesSet
java.lang.Exception
protected void processJob(org.apache.hadoop.mapreduce.Job job) throws java.lang.Exception
java.lang.Exception
public 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
- ユーザー / グループ情報