0

0

C#读写Parquet文件 C#如何处理大数据列式存储Parquet格式

煙雲

煙雲

发布时间:2026-03-14 10:30:41

|

381人浏览过

|

来源于php中文网

原创

ParquetSharp是目前C#生态中稳定支持Parquet读写的主流方案,基于Apache Arrow C++实现,支持.NET 6+,推荐按列读取、显式指定压缩编码、注意DateTime和decimal类型兼容性,并避免全量加载大文件。

c#读写parquet文件 c#如何处理大数据列式存储parquet格式

ParquetSharp 读写 Parquet 文件最可行

目前 C# 生态中稳定支持 Parquet 读写的主流方案是 ParquetSharp(基于 Apache Arrow C++ 实现的 .NET 绑定),而非已停止维护的 parquet-dotnet。它支持 .NET 6+,能处理百万行以上数据,且列式读取逻辑清晰。

安装方式:dotnet add package ParquetSharp。注意:Windows 用户需确保运行时有 vcruntime140.dllmsvcp140.dll(Visual C++ 2015–2022 运行库),否则加载 ParquetSharp.Native 会失败。

  • 不推荐用 Microsoft.Data.Analysis 直接读 Parquet——它底层依赖 ParquetSharp,但封装过深,列过滤、类型映射、内存控制都不透明
  • 避免手动解析二进制:Parquet 是复杂嵌套格式,含页压缩、字典编码、统计信息等,自行解析极易出错且无性能优势
  • ParquetSharp 默认启用 Snappy 压缩;若文件是 GzipZstd 编码,需在 WriterProperties 中显式指定解码器

读取时按需加载列,别全量 ReadTable()

大数据场景下,ParquetFileReader.ReadTable() 会把整个文件解压并转成内存表,极易 OOM。正确做法是只读关键列:

using var reader = new ParquetFileReader("data.parquet");
var schema = reader.Schema;
// 只读第0列(如 "user_id")和第2列(如 "amount")
var columnIndices = new[] { 0, 2 };
using var table = reader.ReadTable(columnIndices);
  • 列索引必须对应 schema 中顺序,不能用字段名直接查——先调 schema.GetFieldIndex("col_name") 获取索引
  • 如果只需某列的统计值(如最大值),可用 ColumnChunkMetaData 直接读 footer 里的 Statistics,完全跳过数据解压
  • 对超大文件(>1GB),建议配合 RowGroupReader 分批读:每个 RowGroup 是独立压缩块,可并行处理

DateTimedecimal 类型容易错位

Parquet 标准对时间与高精度数字的编码有多种逻辑,C# 绑定默认行为可能和 Python/Java 写入端不一致:

Otter.ai
Otter.ai

一个自动的会议记录和笔记工具,会议内容生成和实时转录

下载
  • DateTime:Parquet 常用 INT96INT64 + TIMESTAMP_MILLIS 编码。ParquetSharp 默认按 TIMESTAMP_MICROS 解析,若源文件是毫秒级,需在 ReadOptions 中设 UseLegacyTimestamps = true
  • decimal:.NET 的 decimal 和 Parquet 的 DECIMAL(基于 INT32/INT64/INT128)不是一一映射。读取时若精度丢失,应改用 BigInteger 或字符串暂存,再按 scale 手动除法还原
  • 枚举字段写入前务必转为 intstring,Parquet 不原生支持 .NET enum

写入性能差?关掉默认压缩或换编码

默认 Snappy 压缩在吞吐量敏感场景反而拖慢写入,尤其当 CPU 成瓶颈时:

var props = new WriterProperties(
    compression: CompressionMethod.Uncompressed, // 关压缩
    dictionaryPageSizeThreshold: 0 // 禁用字典编码,适合高基数列
);
using var writer = new ParquetFileWriter("out.parquet", schema, props);
  • 小文件(Zstd(需额外引用 ZstdSharp 并注册 NativeCodec)
  • 字符串列若重复值多,保留字典编码(默认开启),但要设 dictionaryPageSizeThreshold 防止单页过大
  • 写入前确保 schema 中每列的 LogicalType 明确(如 LogicalType.Decimal(precision, scale)),否则读取端可能当成普通整数

真正麻烦的是跨语言协作——Python 用 pyarrow 写的 Parquet,常带 __index_level_0__ 列或自定义元数据,C# 读时得手动跳过这些非业务字段。别指望“自动兼容”,得看 footer 里的 KeyValueMetadata 具体写了啥。

热门AI工具

更多
DeepSeek
DeepSeek

幻方量化公司旗下的开源大模型平台

豆包大模型
豆包大模型

字节跳动自主研发的一系列大型语言模型

WorkBuddy
WorkBuddy

腾讯云推出的AI原生桌面智能体工作台

腾讯元宝
腾讯元宝

腾讯混元平台推出的AI助手

文心一言
文心一言

文心一言是百度开发的AI聊天机器人,通过对话可以生成各种形式的内容。

讯飞写作
讯飞写作

基于讯飞星火大模型的AI写作工具,可以快速生成新闻稿件、品宣文案、工作总结、心得体会等各种文文稿

即梦AI
即梦AI

一站式AI创作平台,免费AI图片和视频生成。

ChatGPT
ChatGPT

最最强大的AI聊天机器人程序,ChatGPT不单是聊天机器人,还能进行撰写邮件、视频脚本、文案、翻译、代码等任务。

相关专题

更多
string转int
string转int

在编程中,我们经常会遇到需要将字符串(str)转换为整数(int)的情况。这可能是因为我们需要对字符串进行数值计算,或者需要将用户输入的字符串转换为整数进行处理。php中文网给大家带来了相关的教程以及文章,欢迎大家前来学习阅读。

1051

2023.08.02

js 字符串转数组
js 字符串转数组

js字符串转数组的方法:1、使用“split()”方法;2、使用“Array.from()”方法;3、使用for循环遍历;4、使用“Array.split()”方法。本专题为大家提供js字符串转数组的相关的文章、下载、课程内容,供大家免费下载体验。

761

2023.08.03

js截取字符串的方法
js截取字符串的方法

js截取字符串的方法有substring()方法、substr()方法、slice()方法、split()方法和slice()方法。本专题为大家提供字符串相关的文章、下载、课程内容,供大家免费下载体验。

221

2023.09.04

java基础知识汇总
java基础知识汇总

java基础知识有Java的历史和特点、Java的开发环境、Java的基本数据类型、变量和常量、运算符和表达式、控制语句、数组和字符串等等知识点。想要知道更多关于java基础知识的朋友,请阅读本专题下面的的有关文章,欢迎大家来php中文网学习。

1570

2023.10.24

字符串介绍
字符串介绍

字符串是一种数据类型,它可以是任何文本,包括字母、数字、符号等。字符串可以由不同的字符组成,例如空格、标点符号、数字等。在编程中,字符串通常用引号括起来,如单引号、双引号或反引号。想了解更多字符串的相关内容,可以阅读本专题下面的文章。

651

2023.11.24

java读取文件转成字符串的方法
java读取文件转成字符串的方法

Java8引入了新的文件I/O API,使用java.nio.file.Files类读取文件内容更加方便。对于较旧版本的Java,可以使用java.io.FileReader和java.io.BufferedReader来读取文件。在这些方法中,你需要将文件路径替换为你的实际文件路径,并且可能需要处理可能的IOException异常。想了解更多java的相关内容,可以阅读本专题下面的文章。

1228

2024.03.22

php中定义字符串的方式
php中定义字符串的方式

php中定义字符串的方式:单引号;双引号;heredoc语法等等。想了解更多字符串的相关内容,可以阅读本专题下面的文章。

1205

2024.04.29

go语言字符串相关教程
go语言字符串相关教程

本专题整合了go语言字符串相关教程,阅读专题下面的文章了解更多详细内容。

193

2025.07.29

TypeScript类型系统进阶与大型前端项目实践
TypeScript类型系统进阶与大型前端项目实践

本专题围绕 TypeScript 在大型前端项目中的应用展开,深入讲解类型系统设计与工程化开发方法。内容包括泛型与高级类型、类型推断机制、声明文件编写、模块化结构设计以及代码规范管理。通过真实项目案例分析,帮助开发者构建类型安全、结构清晰、易维护的前端工程体系,提高团队协作效率与代码质量。

26

2026.03.13

热门下载

更多
网站特效
/
网站源码
/
网站素材
/
前端模板

精品课程

更多
相关推荐
/
热门推荐
/
最新课程
C# 教程
C# 教程

共94课时 | 11.3万人学习

C 教程
C 教程

共75课时 | 5.4万人学习

C++教程
C++教程

共115课时 | 21.8万人学习

关于我们 免责申明 举报中心 意见反馈 讲师合作 广告合作 最新更新
php中文网:公益在线php培训,帮助PHP学习者快速成长!
关注服务号 技术交流群
PHP中文网订阅号
每天精选资源文章推送

Copyright 2014-2026 https://www.php.cn/ All Rights Reserved | php.cn | 湘ICP备2023035733号