org.apache.hadoop.hive.ql.io.udf

Class Rot13OutputFormat

java.lang.Object

<any>

org.apache.hadoop.hive.ql.io.HiveIgnoreKeyTextOutputFormat<LongWritable,Text>

org.apache.hadoop.hive.ql.io.udf.Rot13OutputFormat

All Implemented Interfaces:

HiveOutputFormat<LongWritable,Text>

public class Rot13OutputFormat
extends HiveIgnoreKeyTextOutputFormat<LongWritable,Text>

Nested Class Summary

Nested classes/interfaces inherited from class org.apache.hadoop.hive.ql.io.HiveIgnoreKeyTextOutputFormat

HiveIgnoreKeyTextOutputFormat.IgnoreKeyWriter<K extends WritableComparable,V extends Writable>

Constructor Summary

Constructors

Constructor and Description
Rot13OutputFormat()

Method Summary

Modifier and Type	Method and Description
FileSinkOperator.RecordWriter	getHiveRecordWriter(JobConf jc, Path outPath, java.lang.Class<? extends Writable> valueClass, boolean isCompressed, java.util.Properties tableProperties, Progressable progress) create the final out file, and output row by row.

Methods inherited from class org.apache.hadoop.hive.ql.io.HiveIgnoreKeyTextOutputFormat

getRecordWriter

Methods inherited from class java.lang.Object

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

Constructor Detail

Rot13OutputFormat

public Rot13OutputFormat()

Method Detail

getHiveRecordWriter

public FileSinkOperator.RecordWriter getHiveRecordWriter(JobConf jc,
                                                         Path outPath,
                                                         java.lang.Class<? extends Writable> valueClass,
                                                         boolean isCompressed,
                                                         java.util.Properties tableProperties,
                                                         Progressable progress)
                                                  throws java.io.IOException

Description copied from class: HiveIgnoreKeyTextOutputFormat

create the final out file, and output row by row. After one row is appended, a configured row separator is appended

Specified by:

getHiveRecordWriter in interface HiveOutputFormat<LongWritable,Text>

Overrides:

getHiveRecordWriter in class HiveIgnoreKeyTextOutputFormat<LongWritable,Text>

Parameters:

jc - the job configuration file

outPath - the final output file to be created

valueClass - the value class used for create

isCompressed - whether the content is compressed or not

tableProperties - the tableProperties of this file's corresponding table

progress - progress used for status report

Returns:

the RecordWriter

Throws:

java.io.IOException