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.BeanNameAwareJobFactoryBean とは異なり、このファクトリはストリーミングシナリオ (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.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.Exceptionpublic 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 - ユーザー / グループ情報