温馨提示：要看高清无码套图，请使用手机打开并单击图片放大查看。
1.简介
本篇文章主要讲如何使用java生成Avro格式数据以及如何通过spark将Avro数据文件转换成DataSet和DataFrame进行操作。
1.1Apache Arvo是什么？
Apache Avro 是一个数据序列化系统，Avro提供Java、Python、C、C++、C#等语言API接口，下面我们通过java的一个实例来说明Avro序列化和反序列化数据。
- 支持丰富的数据结构
- 快速可压缩的二进制数据格式
- 存储持久数据的文件容器
- 远程过程调用（RPC）
- 动态语言的简单集成
2.Avro数据生成
2.1定义Schema文件
1.下载avro-tools-1.8.1.jar
Avro官网：http://avro.apache.org/ Avro版本：1.8.1 下载Avro相关jar包：avro-tools-1.8.1.jar 该jar包主要用户将定义好的schema文件生成对应的java文件
2.定义一个schema文件，命名为CustomerAdress.avsc
{
"namespace":"com.peach.arvo",
"type": "record",
"name": "CustomerAddress",
"fields": [
{"name":"ca_address_sk","type":"long"},
{"name":"ca_address_id","type":"string"},
{"name":"ca_street_number","type":"string"},
{"name":"ca_street_name","type":"string"},
{"name":"ca_street_type","type":"string"},
{"name":"ca_suite_number","type":"string"},
{"name":"ca_city","type":"string"},
{"name":"ca_county","type":"string"},
{"name":"ca_state","type":"string"},
{"name":"ca_zip","type":"string"},
{"name":"ca_country","type":"string"},
{"name":"ca_gmt_offset","type":"double"},
{"name":"ca_location_type","type":"string"}
]
}
Schema说明：
- namespace：在生成java文件时import包路径
- type：omplex types（record, enum,array, map, union, and fixed）
- name：生成java文件时的类名
- fileds：schema中定义的字段及类型
3.生成java代码文件
使用第1步下载的avro-tools-1.8.1.jar包，生成java code
java -jar avro-tools-1.8.1.jar compile schema CustomerAddress.avsc .
末尾的"."代表java code 生成在当前目录，命令执行成功后显示：
![]()
2.2使用Java生成Avro文件
1.使用Maven创建java工程
在pom.xml文件中添加如下依赖
org.apache.avro
avro
1.8.1
![]()
2.新建java类GenerateDataApp，代码如下
![]()
![]()
![]()
动态生成avro文件，通过将数据封装为GenericRecord对象，动态的写入avro文件，以下代码片段：
![]()
3. Spark读Avro文件
1.使用Maven创建一个scala工程
在pom.xml文件中增加如下依赖
![]()
![]()
2.Scala事例代码片段
![]()
3.Spark运行结果
![]()
源码地址：
https://github.com/javaxsky/avrotospark
醉酒鞭名马，少年多浮夸！ 岭南浣溪沙，呕吐酒肆下！挚友不肯放，数据玩的花！
温馨提示：要看高清无码套图，请使用手机打开并单击图片放大查看。
