public class StreamJobFactoryBean
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
JobFactoryBean
とは異なり、このファクトリはストリーミングシナリオ (Ruby/Python スクリプトやコマンドラインスクリプトの呼び出しなど) に適しています。コンストラクターと説明 |
---|
StreamJobFactoryBean() |
修飾子と型 | メソッドと説明 |
---|---|
void | afterPropertiesSet() |
org.apache.hadoop.mapreduce.Job | getObject() |
java.lang.Class<?> | getObjectType() |
boolean | isSingleton() |
void | setArchives(org.springframework.core.io.Resource... archives) マップ削減クラスターにアーカイブ解除するアーカイブを設定します。 |
void | setBeanName(java.lang.String name) |
void | setCmdEnv(java.util.Properties cmdEnv) 実行されるコマンドの環境を設定します。 |
void | setCombiner(java.lang.String combiner) ジョブコンバイナーを設定します。 |
void | setConfiguration(org.apache.hadoop.conf.Configuration configuration) 使用する Hadoop 構成を設定します。 |
void | setFiles(org.springframework.core.io.Resource... files) マップ削減クラスターにコピーするファイルを設定します。 |
void | setInputFormat(java.lang.String inputFormat) ジョブの入力形式を設定します。 |
void | setInputPath(java.lang.String... input) ジョブ入力パスを設定します。 |
void | setLibs(org.springframework.core.io.Resource... libJars) クラスパスに含める jar ファイルを設定します。 |
void | setMapper(java.lang.String mapper) ジョブマッパーを設定します。 |
void | setNumberReducers(java.lang.Integer numReduceTasks) リデューサータスクのジョブ番号を設定します。 |
void | setOutputFormat(java.lang.String outputFormat) ジョブの出力形式を設定します。 |
void | setOutputPath(java.lang.String output) ジョブの出力パスを設定します。 |
void | setPartitioner(java.lang.String partitioner) ジョブパーティショナーを設定します。 |
void | setProperties(java.util.Properties properties) 使用する構成プロパティを設定します。 |
void | setReducer(java.lang.String reducer) ジョブリデューサーを設定します。 |
void | setUser(java.lang.String user) このジョブを実行するためのユーザーの偽装 (オプション) を設定します。 |
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
public void setInputPath(java.lang.String... input)
input
- 設定する入力。public void setOutputPath(java.lang.String output)
output
- 設定する出力。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 setConfiguration(org.apache.hadoop.conf.Configuration configuration)
configuration
- 設定する構成。public void setCmdEnv(java.util.Properties cmdEnv)
cmdEnv
- 設定する環境コマンド / プロパティ。public void setNumberReducers(java.lang.Integer numReduceTasks)
numReduceTasks
- 設定する numReduceTasks。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
- ユーザー / グループ情報