這篇文章給大家分享的是有關Hadoop2.6.0中InputFormat和OutputFormat的用法示例的內容。小編覺得挺實用的，因此分享給大家做個參考，一起跟隨小編過來看看吧。

成都創新互聯公司專注于三都網站建設服務及定制，我們擁有豐富的企業做網站經驗。 熱誠為您提供三都營銷型網站建設，三都網站制作、三都網頁設計、三都網站官網定制、重慶小程序開發服務，打造三都網絡公司原創品牌,更為您提供三都網站排名全網營銷落地服務。

java.lang.Object
    org.apache.hadoop.mapreduce.InputFormat<K, V>
        org.apache.hadoop.mapreduce.lib.db.DBInputFormat<T extends DBWritable>
            DataDrivenDBInputFormat<T extends DBWritable>
                OracleDataDrivenDBInputFormat<T extends DBWritable>
        org.apache.hadoop.mapreduce.lib.input.FileInputFormat<K, V>
            CombineFileInputFormat<K, V>
                CombineSequenceFileInputFormat<K,V>
                CombineTextInputFormat<LongWritable,Text>
            FixedLengthInputFormat<LongWritable, BytesWritable>
            KeyValueTextInputFormat<Text, Text>
            NLineInputFormat<LongWritable, Text>
            SequenceFileInputFormat<K, V>
            TextInputFormat<LongWritable, Text>

InputFormat

public abstract class InputFormat<K, V> {
  public abstract List<InputSplit> getSplits(JobContext context) throws IOException, InterruptedException;
                               
  public abstract RecordReader<K,V> createRecordReader(InputSplit split,TaskAttemptContext context)
                                                        throws IOException,  InterruptedException;
}

1、FileInputFormat

1.1 TextInputFormat

1.2 KeyValueTextInputFormat

1.3 SequenceFileInputFormat

1.4 CombineFileInputFormat

1.5 FixedLengthInputFormat

1.6 NLineInputFormat

2、DBInputFormat

2.1 DataDrivenDBInputFormat

2.1.1 OracleDataDrivenDBInputFormat

OutputFormat

public abstract class OutputFormat<K, V> {
    public abstract RecordWriter<K, V> getRecordWriter(TaskAttemptContext context
                    ) throws IOException, InterruptedException;
                    
    public abstract RecordWriter<K, V> getRecordWriter(TaskAttemptContext context
                    ) throws IOException, InterruptedException;
                    
    public abstract OutputCommitter getOutputCommitter(TaskAttemptContext context
                    ) throws IOException, InterruptedException;
}

感謝各位的閱讀！關于“Hadoop2.6.0中InputFormat和OutputFormat的用法示例”這篇文章就分享到這里了，希望以上內容可以對大家有一定的幫助，讓大家可以學到更多知識，如果覺得文章不錯，可以把它分享出去讓更多的人看到吧！

文章標題：Hadoop2.6.0中InputFormat和OutputFormat的用法示例
標題網址：http://vcdvsql.cn/article22/jhipjc.html

成都網站建設公司_創新互聯，為您提供網站設計公司、網頁設計公司、小程序開發、服務器托管、用戶體驗、網站設計

廣告

聲明：本網站發布的內容（圖片、視頻和文字）以用戶投稿、用戶轉載內容為主，如果涉及侵權請盡快告知，我們將會在第一時間刪除。文章觀點不代表本網站立場，如需處理請聯系客服。電話：028-86922220；郵箱：631063699@qq.com。內容未經允許不得轉載，或轉載時需注明來源： 創新互聯