2016-10-29 4 views

答えて

2

これはorg.apache.hadoop.conf.Configurationを使用して構成され、詳細は使用するInputFormatに依存します。例えば、TextInputFormatmapred.input.dirを使用します。

一般に、ファイルベースのソースを使用する場合は、newAPIHadoopFileを使用します。

+0

基本的に、ディレクトリ内のファイル(my_input_dir)を設定してからval c = new Configuration(sc.hadoopConfiguration)を設定します。 c.set( "mapred.input.dir"、 "my_input_dir"); – pythonic

関連する問題