org.apache.hadoop.mapreduce.lib.output

クラス SequenceFileAsBinaryOutputFormat

java.lang.Object

org.apache.hadoop.mapreduce.OutputFormat<K,V>

org.apache.hadoop.mapreduce.lib.output.FileOutputFormat<K,V>

org.apache.hadoop.mapreduce.lib.output.SequenceFileOutputFormat<BytesWritable,BytesWritable>

org.apache.hadoop.mapreduce.lib.output.SequenceFileAsBinaryOutputFormat

@InterfaceAudience.Public
 @InterfaceStability.Stable
public class SequenceFileAsBinaryOutputFormat
extends SequenceFileOutputFormat<BytesWritable,BytesWritable>

An OutputFormat that writes keys, values to SequenceFiles in binary(raw) format

フィールドのサマリー

フィールド

修飾子とタイプ	フィールドと説明
static String	KEY_CLASS
static String	VALUE_CLASS

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

BASE_OUTPUT_NAME, COMPRESS, COMPRESS_CODEC, COMPRESS_TYPE, OUTDIR, PART

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

コンストラクタ

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

メソッドのサマリー

修飾子とタイプ	メソッドと説明
void	checkOutputSpecs(JobContext job) Check for validity of the output-specification for the job.
RecordWriter<BytesWritable,BytesWritable>	getRecordWriter(TaskAttemptContext context) Get the RecordWriter for the given task.
static Class<? extends WritableComparable>	getSequenceFileOutputKeyClass(JobContext job) Get the key class for the SequenceFile
static Class<? extends Writable>	getSequenceFileOutputValueClass(JobContext job) Get the value class for the SequenceFile
static void	setSequenceFileOutputKeyClass(Job job, Class<?> theClass) Set the key class for the SequenceFile This allows the user to specify the key class to be different from the actual class (BytesWritable) used for writing
static void	setSequenceFileOutputValueClass(Job job, Class<?> theClass) Set the value class for the SequenceFile This allows the user to specify the value class to be different from the actual class (BytesWritable) used for writing

クラスから継承されたメソッド org.apache.hadoop.mapreduce.lib.output.SequenceFileOutputFormat

getOutputCompressionType, getSequenceWriter, setOutputCompressionType

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

getCompressOutput, getDefaultWorkFile, getOutputCommitter, getOutputCompressorClass, getOutputName, getOutputPath, getPathForWorkFile, getUniqueFile, getWorkOutputPath, setCompressOutput, setOutputCompressorClass, setOutputName, setOutputPath

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

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

フィールドの詳細

KEY_CLASS

public static String KEY_CLASS

VALUE_CLASS

public static String VALUE_CLASS

コンストラクタの詳細

SequenceFileAsBinaryOutputFormat

public SequenceFileAsBinaryOutputFormat()

メソッドの詳細

setSequenceFileOutputKeyClass

public static void setSequenceFileOutputKeyClass(Job job,
                                                 Class<?> theClass)

Set the key class for the SequenceFile

This allows the user to specify the key class to be different from the actual class (BytesWritable) used for writing

パラメータ:

job - the Job to modify

theClass - the SequenceFile output key class.

setSequenceFileOutputValueClass

public static void setSequenceFileOutputValueClass(Job job,
                                                   Class<?> theClass)

Set the value class for the SequenceFile

This allows the user to specify the value class to be different from the actual class (BytesWritable) used for writing

パラメータ:

job - the Job to modify

theClass - the SequenceFile output key class.

getSequenceFileOutputKeyClass

public static Class<? extends WritableComparable> getSequenceFileOutputKeyClass(JobContext job)

Get the key class for the SequenceFile

戻り値:

the key class of the SequenceFile

getSequenceFileOutputValueClass

public static Class<? extends Writable> getSequenceFileOutputValueClass(JobContext job)

Get the value class for the SequenceFile

戻り値:

the value class of the SequenceFile

getRecordWriter

public RecordWriter<BytesWritable,BytesWritable> getRecordWriter(TaskAttemptContext context)
                                                          throws IOException

クラスからコピーされた説明: OutputFormat

Get the RecordWriter for the given task.

オーバーライド:

getRecordWriter クラス内 SequenceFileOutputFormat<BytesWritable,BytesWritable>

パラメータ:

context - the information about the current task.

戻り値:

a RecordWriter to write the output for the job.

例外:

IOException

checkOutputSpecs

public void checkOutputSpecs(JobContext 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 クラス内 FileOutputFormat<BytesWritable,BytesWritable>

パラメータ:

job - information about the job

例外:

IOException - when output should not be attempted