org.apache.hadoop.mapred.lib

クラス LazyOutputFormat<K,V>

java.lang.Object

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

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

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

OutputFormat<K,V>

@InterfaceAudience.Public
 @InterfaceStability.Stable
public class LazyOutputFormat<K,V>
extends FilterOutputFormat<K,V>

A Convenience class that creates output lazily.

フィールドのサマリー

クラスから継承されたフィールド org.apache.hadoop.mapred.lib.FilterOutputFormat

baseOut

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

コンストラクタ

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

メソッドのサマリー

修飾子とタイプ	メソッドと説明
void	checkOutputSpecs(FileSystem ignored, JobConf job) Check for validity of the output-specification for the job.
RecordWriter<K,V>	getRecordWriter(FileSystem ignored, JobConf job, String name, Progressable progress) Get the RecordWriter for the given job.
static void	setOutputFormatClass(JobConf job, Class<? extends OutputFormat> theClass) Set the underlying output format for LazyOutputFormat.

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

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

コンストラクタの詳細

LazyOutputFormat

public LazyOutputFormat()

メソッドの詳細

setOutputFormatClass

public static void setOutputFormatClass(JobConf job,
                                        Class<? extends OutputFormat> theClass)

Set the underlying output format for LazyOutputFormat.

パラメータ:

job - the JobConf to modify

theClass - the underlying class

getRecordWriter

public RecordWriter<K,V> getRecordWriter(FileSystem ignored,
                                         JobConf job,
                                         String name,
                                         Progressable progress)
                                  throws IOException

インタフェースからコピーされた説明: OutputFormat

Get the RecordWriter for the given job.

定義:

getRecordWriter インタフェース内 OutputFormat<K,V>

オーバーライド:

getRecordWriter クラス内 FilterOutputFormat<K,V>

job - configuration for the job whose output is being written.

name - the unique name for this part of the output.

progress - mechanism for reporting progress while writing to file.

戻り値:

a RecordWriter to write the output for the job.

例外:

IOException

checkOutputSpecs

public void checkOutputSpecs(FileSystem ignored,
                             JobConf job)
                      throws IOException

インタフェースからコピーされた説明: OutputFormat

Check for validity of the output-specification for the job.

This is to validate the output specification for the job when it is a job is submitted. Typically checks that it does not already exist, throwing an exception when it already exists, so that output is not overwritten.

定義:

checkOutputSpecs インタフェース内 OutputFormat<K,V>

オーバーライド:

checkOutputSpecs クラス内 FilterOutputFormat<K,V>

job - job configuration.

例外:

IOException - when output should not be attempted