org.apache.hadoop.mapred.lib

クラス MultipleTextOutputFormat<K,V>

java.lang.Object

org.apache.hadoop.mapred.FileOutputFormat<K,V>

org.apache.hadoop.mapred.lib.MultipleOutputFormat<K,V>

org.apache.hadoop.mapred.lib.MultipleTextOutputFormat<K,V>

すべての実装されたインタフェース:

OutputFormat<K,V>

@InterfaceAudience.Public
 @InterfaceStability.Stable
public class MultipleTextOutputFormat<K,V>
extends MultipleOutputFormat<K,V>

This class extends the MultipleOutputFormat, allowing to write the output data to different output files in Text output format.

コンストラクタのサマリー

コンストラクタ

コンストラクタと説明
MultipleTextOutputFormat()

メソッドのサマリー

修飾子とタイプ	メソッドと説明
protected RecordWriter<K,V>	getBaseRecordWriter(FileSystem fs, JobConf job, String name, Progressable arg3)

クラスから継承されたメソッド org.apache.hadoop.mapred.lib.MultipleOutputFormat

generateActualKey, generateActualValue, generateFileNameForKeyValue, generateLeafFileName, getInputFileBasedOutputFileName, getRecordWriter

クラスから継承されたメソッド org.apache.hadoop.mapred.FileOutputFormat

checkOutputSpecs, getCompressOutput, getOutputCompressorClass, getOutputPath, getPathForCustomFile, getTaskOutputPath, getUniqueName, getWorkOutputPath, setCompressOutput, setOutputCompressorClass, setOutputPath

クラスから継承されたメソッド java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

コンストラクタの詳細

MultipleTextOutputFormat

public MultipleTextOutputFormat()

メソッドの詳細

getBaseRecordWriter

protected RecordWriter<K,V> getBaseRecordWriter(FileSystem fs,
                                                JobConf job,
                                                String name,
                                                Progressable arg3)
                                         throws IOException

定義:

getBaseRecordWriter クラス内 MultipleOutputFormat<K,V>

パラメータ:

fs - the file system to use

job - a job conf object

name - the name of the file over which a record writer object will be constructed

arg3 - a progressable object

戻り値:

A RecordWriter object over the given file

例外:

IOException