java 读写Parquet格式的数据的示例代码
发布时间 - 2026-01-11 03:22:51 点击率:次本文介绍了java 读写Parquet格式的数据,分享给大家,具体如下:
import java.io.BufferedReader;
import java.io.File;
import java.io.FileReader;
import java.io.IOException;
import java.util.Random;
import org.apache.hadoop.conf.Configuration;
import org.apache.hadoop.fs.Path;
import org.apache.log4j.Logger;
import org.apache.parquet.example.data.Group;
import org.apache.parquet.example.data.GroupFactory;
import org.apache.parquet.example.data.simple.SimpleGroupFactory;
import org.apache.parquet.hadoop.ParquetReader;
import org.apache.parquet.hadoop.ParquetReader.Builder;
import org.apache.parquet.hadoop.ParquetWriter;
import org.apache.parquet.hadoop.example.GroupReadSupport;
import org.apache.parquet.hadoop.example.GroupWriteSupport;
import org.apache.parquet.schema.MessageType;
import org.apache.parquet.schema.MessageTypeParser;
public class ReadParquet {
static Logger logger=Logger.getLogger(ReadParquet.class);
public static void main(String[] args) throws Exception {
// parquetWriter("test\\parquet-out2","input.txt");
parquetReaderV2("test\\parquet-out2");
}
static void parquetReaderV2(String inPath) throws Exception{
GroupReadSupport readSupport = new GroupReadSupport();
Builder<Group> reader= ParquetReader.builder(readSupport, new Path(inPath));
ParquetReader<Group> build=reader.build();
Group line=null;
while((line=build.read())!=null){
Group time= line.getGroup("time", 0);
//通过下标和字段名称都可以获取
/*System.out.println(line.getString(0, 0)+"\t"+
line.getString(1, 0)+"\t"+
time.getInteger(0, 0)+"\t"+
time.getString(1, 0)+"\t");*/
System.out.println(line.getString("city", 0)+"\t"+
line.getString("ip", 0)+"\t"+
time.getInteger("ttl", 0)+"\t"+
time.getString("ttl2", 0)+"\t");
//System.out.println(line.toString());
}
System.out.println("读取结束");
}
//新版本中new ParquetReader()所有构造方法好像都弃用了,用上面的builder去构造对象
static void parquetReader(String inPath) throws Exception{
GroupReadSupport readSupport = new GroupReadSupport();
ParquetReader<Group> reader = new ParquetReader<Group>(new Path(inPath),readSupport);
Group line=null;
while((line=reader.read())!=null){
System.out.println(line.toString());
}
System.out.println("读取结束");
}
/**
*
* @param outPath 输出Parquet格式
* @param inPath 输入普通文本文件
* @throws IOException
*/
static void parquetWriter(String outPath,String inPath) throws IOException{
MessageType schema = MessageTypeParser.parseMessageType("message Pair {\n" +
" required binary city (UTF8);\n" +
" required binary ip (UTF8);\n" +
" repeated group time {\n"+
" required int32 ttl;\n"+
" required binary ttl2;\n"+
"}\n"+
"}");
GroupFactory factory = new SimpleGroupFactory(schema);
Path path = new Path(outPath);
Configuration configuration = new Configuration();
GroupWriteSupport writeSupport = new GroupWriteSupport();
writeSupport.setSchema(schema,configuration);
ParquetWriter<Group> writer = new ParquetWriter<Group>(path,configuration,writeSupport);
//把本地文件读取进去,用来生成parquet格式文件
BufferedReader br =new BufferedReader(new FileReader(new File(inPath)));
String line="";
Random r=new Random();
while((line=br.readLine())!=null){
String[] strs=line.split("\\s+");
if(strs.length==2) {
Group group = factory.newGroup()
.append("city",strs[0])
.append("ip",strs[1]);
Group tmpG =group.addGroup("time");
tmpG.append("ttl", r.nextInt(9)+1);
tmpG.append("ttl2", r.nextInt(9)+"_a");
writer.write(group);
}
}
System.out.println("write end");
writer.close();
}
}
说下schema(写Parquet格式数据需要schema,读取的话"自动识别"了schema)
/* * 每一个字段有三个属性:重复数、数据类型和字段名,重复数可以是以下三种: * required(出现1次) * repeated(出现0次或多次) * optional(出现0次或1次) * 每一个字段的数据类型可以分成两种: * group(复杂类型) * primitive(基本类型) * 数据类型有 * INT64, INT32, BOOLEAN, BINARY, FLOAT, DOUBLE, INT96, FIXED_LEN_BYTE_ARRAY */
这个repeated和required 不光是次数上的区别,序列化后生成的数据类型也不同,比如repeqted修饰 ttl2 打印出来为 WrappedArray([7,7_a]) 而 required修饰 ttl2 打印出来为 [7,7_a] 除了用MessageTypeParser.parseMessageType类生成MessageType 还可以用下面方法
(注意这里有个坑--spark里会有这个问题--ttl2这里 as(OriginalType.UTF8) 和 required binary city (UTF8)作用一样,加上UTF8,在读取的时候可以转为StringType,不加的话会报错 [B cannot be cast to java.lang.String )
/*MessageType schema = MessageTypeParser.parseMessageType("message Pair {\n" +
" required binary city (UTF8);\n" +
" required binary ip (UTF8);\n" +
"repeated group time {\n"+
"required int32 ttl;\n"+
"required binary ttl2;\n"+
"}\n"+
"}");*/
//import org.apache.parquet.schema.Types;
MessageType schema = Types.buildMessage()
.required(PrimitiveTypeName.BINARY).as(OriginalType.UTF8).named("city")
.required(PrimitiveTypeName.BINARY).as(OriginalType.UTF8).named("ip")
.repeatedGroup().required(PrimitiveTypeName.INT32).named("ttl")
.required(PrimitiveTypeName.BINARY).as(OriginalType.UTF8).named("ttl2")
.named("time")
.named("Pair");
解决 [B cannot be cast to java.lang.String 异常:
1.要么生成parquet文件的时候加个UTF8
2.要么读取的时候再提供一个同样的schema类指定该字段类型,比如下面:
maven依赖(我用的1.7)
<dependency> <groupId>org.apache.parquet</groupId> <artifactId>parquet-hadoop</artifactId> <version>1.7.0</version> </dependency>
以上就是本文的全部内容,希望对大家的学习有所帮助,也希望大家多多支持。
# java读写parquet文件
# java
# parquet
# 读写
# java写parquet文件
# java 序列化对象 serializable 读写数据的实例
# Java基于字符流形式读写数据的两种实现方法示例
# Java操作IO对象流进行数据的读写
# Java如何利用Socket进行数据读写
# 详解Java编写算法时如何加快读写数据速度
# 打印出来
# 会有
# 有个
# 两种
# 可以用
# 这个问题
# 我用
# 用了
# 自动识别
# 给大家
# 三种
# 报错
# 不加
# 新版本
# 大家多多
# 文本文件
# 再提
# 字段名
# 序列化
# logger
相关栏目:
【
网站优化151355 】
【
网络推广146373 】
【
网络技术251813 】
【
AI营销90571 】
相关推荐:
百度输入法ai面板怎么关 百度输入法ai面板隐藏技巧
Python文本处理实践_日志清洗解析【指导】
在线制作视频的网站有哪些,电脑如何制作视频短片?
利用 Google AI 进行 YouTube 视频 SEO 描述优化
JavaScript如何实现类型判断_typeof和instanceof有什么区别
Claude怎样写结构化提示词_Claude结构化提示词写法【教程】
Laravel如何实现用户角色和权限系统_Laravel角色权限管理机制
如何快速上传建站程序避免常见错误?
黑客如何利用漏洞与弱口令入侵网站服务器?
如何在 React 中条件性地遍历数组并渲染元素
大连 网站制作,大连天途有线官网?
如何在建站之星绑定自定义域名?
Laravel API资源类怎么用_Laravel API Resource数据转换
微信小程序 wx.uploadFile无法上传解决办法
电视网站制作tvbox接口,云海电视怎样自定义添加电视源?
Thinkphp 中 distinct 的用法解析
Laravel中间件起什么作用_Laravel Middleware请求生命周期与自定义详解
网站广告牌制作方法,街上的广告牌,横幅,用PS还是其他软件做的?
Laravel辅助函数有哪些_Laravel Helpers常用助手函数大全
实现点击下箭头变上箭头来回切换的两种方法【推荐】
laravel怎么实现图片的压缩和裁剪_laravel图片压缩与裁剪方法
Bootstrap整体框架之JavaScript插件架构
如何用PHP工具快速搭建高效网站?
微信小程序 require机制详解及实例代码
如何用AWS免费套餐快速搭建高效网站?
Laravel如何使用Service Container和依赖注入?(代码示例)
在Oracle关闭情况下如何修改spfile的参数
网页制作模板网站推荐,网页设计海报之类的素材哪里好?
Laravel如何集成微信支付SDK_Laravel使用yansongda-pay实现扫码支付【实战】
Laravel如何集成第三方登录_Laravel Socialite实现微信QQ微博登录
Laravel如何实现模型的全局作用域?(Global Scope示例)
香港服务器网站测试全流程:性能评估、SEO加载与移动适配优化
Laravel控制器是什么_Laravel MVC架构中Controller的作用与实践
python中快速进行多个字符替换的方法小结
如何快速生成高效建站系统源代码?
详解Nginx + Tomcat 反向代理 负载均衡 集群 部署指南
如何用虚拟主机快速搭建网站?详细步骤解析
C++时间戳转换成日期时间的步骤和示例代码
🚀拖拽式CMS建站能否实现高效与个性化并存?
浅述节点的创建及常见功能的实现
微信公众帐号开发教程之图文消息全攻略
Python进程池调度策略_任务分发说明【指导】
Laravel如何配置和使用缓存?(Redis代码示例)
Linux系统命令中tree命令详解
Laravel 419 page expired怎么解决_Laravel CSRF令牌过期处理
PHP 500报错的快速解决方法
Windows10如何删除恢复分区_Win10 Diskpart命令强制删除分区
深圳网站制作的公司有哪些,dido官方网站?
Win11搜索栏无法输入_解决Win11开始菜单搜索没反应问题【技巧】
Laravel怎么进行浏览器测试_Laravel Dusk自动化浏览器测试入门

