`
dajuezhao
  • 浏览: 60869 次
  • 性别: Icon_minigender_1
  • 来自: 北京
社区版块
存档分类
最新评论

Hadoop开发常用的InputFormat和OutputFormat(转)

阅读更多

Hadoop中的Map Reduce框架依赖InputFormat提供数据,依赖OutputFormat输出数据;每一个Map Reduce程序都离不开他们。Hadoop提供了一系列InputFormat和OutputFormat方便开发,本文介绍几种常用的。

TextInputFormat
用于读取纯文本文件,文件被分为一系列以LF或者CR结束的行,key是每一行的位置(偏移量,LongWritable类型),value是每一行的内容,Text类型。

KeyValueTextInputFormat
同样用于读取文件,如果行被分隔符(缺省是tab)分割为两部分,第一部分为key,剩下的部分为value;如果没有分隔符,整行作为 key,value为空

SequenceFileInputFormat
用于读取sequence file。 sequence file是Hadoop用于存储数据自定义格式的binary文件。它有两个子类:SequenceFileAsBinaryInputFormat,将 key和value以BytesWritable的类型读出;SequenceFileAsTextInputFormat,将key和value以 Text的类型读出。

SequenceFileInputFilter
根据filter从sequence文件中取得部分满足条件的数据,通过setFilterClass指定Filter,内置了三种 Filter,RegexFilter取key值满足指定的正则表达式的记录;PercentFilter通过指定参数f,取记录行数%f==0的记录;MD5Filter通过指定参数f,取MD5(key)%f==0的记录。

NLineInputFormat
0.18.x新加入,可以将文件以行为单位进行split,比如文件的每一行对应一个map。得到的key是每一行的位置(偏移量,LongWritable类型),value是每一行的内容,Text类型。

CompositeInputFormat,用于多个数据源的join。

TextOutputFormat,输出到纯文本文件,格式为 key + " " + value。

NullOutputFormat,hadoop中的/dev/null,将输出送进黑洞。

SequenceFileOutputFormat, 输出到sequence file格式文件。

MultipleSequenceFileOutputFormat, MultipleTextOutputFormat,根据key将记录输出到不同的文件。

DBInputFormat和DBOutputFormat,从DB读取,输出到DB。

分享到:
评论

相关推荐

    实战hadoop中的源码

    7. **扩展性与插件开发**:学习如何为Hadoop开发自定义InputFormat、OutputFormat、Partitioner、Combiner等组件。 8. **实战项目**:结合实际案例,运用所学知识解决大数据处理问题,如日志分析、推荐系统等。 ...

    hadoop 文档:Hadoop开发者下载

    3. **开发环境搭建**:安装和配置Hadoop开发环境是开发者的第一步,包括Java环境、Hadoop版本选择、配置Hadoop环境变量、集群部署或伪分布式部署等。 4. **Hadoop API**:学习使用Hadoop API进行数据读写和处理,...

    hadoop2lib.tar.gz

    例如,使用Hadoop的InputFormat和OutputFormat接口,开发者可以定义自定义的数据输入和输出格式。同时,Hadoop的Configuration类使得配置参数变得简单,而FileSystem API则允许开发者操作HDFS上的文件。 在实际开发...

    hadoop eclipse mapreduce 下开发所有需要用到的 JAR 包

    在Hadoop生态系统中,Eclipse是一个常用的集成开发环境(IDE),用于编写MapReduce程序。MapReduce是一种编程模型,用于大规模数据集的并行处理。它将大数据任务分解为两个主要阶段:映射(Map)和化简(Reduce)。...

    hadoop开发所需类

    6. **InputFormat 和 OutputFormat**:`InputFormat`定义如何将输入数据分割为键值对,而`OutputFormat`规定如何将Reduce阶段的结果写回。常见的实现有`TextInputFormat`和`TextOutputFormat`,但可以根据需求自定义...

    hadoop-lzo-master.zip

    Hadoop-LZO不仅提供了对LZO压缩格式的支持,还包含了用于Hadoop的InputFormat和OutputFormat,使得Hadoop可以直接处理LZO压缩的数据。 二、LZO压缩算法 LZO(Lempel-Ziv-Oberhumer)是一种实时数据压缩算法,它...

    hadoop 开发者入门专刊 1-4

    6. Hadoop数据输入与输出:学习如何使用InputFormat和OutputFormat进行数据读取和写入,以及自定义InputFormat和OutputFormat的方法。 7. Hadoop作业提交与监控:了解如何使用Hadoop命令行工具提交作业,以及如何...

    hadoop-2.7.3源码和安装包.zip

    5. **数据输入与输出**:学习如何使用Hadoop的InputFormat和OutputFormat接口自定义数据格式,以及如何使用`hadoop fs`命令操作HDFS。 6. **应用程序开发**:掌握如何编写MapReduce程序,理解Mapper和Reducer的工作...

    Hadoop教程(二)Java开发Java经验技巧共5页

    对于Hadoop开发,尤其需要熟悉集合框架,如List、Set和Map,以及多线程和并发处理,因为Hadoop作业往往涉及大量的数据处理和并行计算。 其次,深入学习Hadoop MapReduce是Java开发的关键环节。MapReduce是一种编程...

    完整版大数据云计算课程 Hadoop数据分析平台系列课程 Hadoop 05 Hadoop API开发 共32页.rar

    在本课程中,我们将深入探讨Hadoop API的开发,这是大数据云计算领域中的核心部分,尤其对于数据处理和分析至关重要。Hadoop是Apache软件基金会开源的一个分布式计算框架,它允许高效地处理海量数据集,是大数据处理...

    hadoop应用开发技术详解代码

    - 自定义InputFormat和OutputFormat:根据实际需求定制数据输入输出格式。 - 分析日志数据:使用MapReduce处理大量服务器日志,提取有价值信息。 - 处理复杂数据结构:例如XML或JSON文件的解析和处理。 6. **...

    Hadoop源代码分析

    用户可以通过自定义InputFormat和OutputFormat来处理特定格式的数据。 4. **Mapper与Reducer**:Mapper是用户编写的数据处理逻辑,通常用于过滤、转换数据。Reducer则负责聚合Mapper的输出,进行汇总或计算。在某些...

    Hadoop的jar包

    Hadoop是一个开源的分布式计算框架,它允许在廉价硬件上处理和存储大量数据。这个压缩包文件包含了运行和开发...总的来说,这个压缩包是一个完整的Hadoop开发环境的基础,对于学习和实践Hadoop技术的人来说非常有价值。

    hadoop的JAVA编程包

    - **InputFormat和OutputFormat**:定义数据的输入和输出格式,例如`TextInputFormat`和`TextOutputFormat`。 - **RecordReader和RecordWriter**:解析输入数据和写入输出数据的接口。 5. **Hadoop的容错机制** ...

    hadoop 入门

    此外,还需要理解InputFormat和OutputFormat,它们定义了数据的读取和写入格式。 Hadoop还提供了Pig和Hive等高级数据处理语言,使得非Java背景的开发者也能便捷地使用Hadoop。Pig提供了一种脚本语言(Pig Latin),...

    Hadoop应用开发技术详解

    2. **Hadoop开发环境** - **Hadoop安装与配置**: 包括单机模式、伪分布式模式和完全分布式模式的搭建步骤。 - **Eclipse插件与IntelliJ IDEA支持**: 开发者可以使用这些集成开发环境(IDE)配合Hadoop插件进行便捷...

    Hadoop大数据开发教程笔记软件.zip

    这通常涉及到InputFormat、OutputFormat、Mapper和Reducer类的使用。 4. **YARN资源管理**:了解新一代的资源调度器YARN,包括ResourceManager、NodeManager、ApplicationMaster的角色和它们之间的交互,以及如何...

    Hadoop大数据开发实战-代码.rar

    代码可能包括Mapper和Reducer类的实现,以及InputFormat和OutputFormat的配置。 3. Hadoop Streaming:这是一种使用任意可执行程序(如Python、Perl)作为Mapper和Reducer的方法。压缩包可能包含使用Shell脚本或...

    hadoop-common-2.7.1-bin-master.zip

    4. **I/O库和接口**:Hadoop Common还提供了各种I/O接口和类,如InputFormat和OutputFormat接口,用于定义数据读取和写入的方式;RecordReader和RecordWriter,处理输入和输出记录的类;以及各种压缩和编码算法,如...

    Hadoop开发者入门-带书签文字版

    6. **数据输入与输出**:学习如何使用Hadoop的InputFormat和OutputFormat,以及RecordReader和RecordWriter,实现对不同格式数据的读写。 7. **Hadoop安全**:理解Hadoop的安全特性,如Kerberos认证、访问控制列表...

Global site tag (gtag.js) - Google Analytics