使用场景
使用 Smallpond 对股票价格数据进行分析,计算每日最高价和最低价
在大规模数据集上运行 GraySort 基准测试,验证数据处理性能
结合 3FS 存储系统,实现分布式数据处理和存储
产品特色
高性能数据处理:基于 DuckDB 提供快速的数据查询和处理能力
可扩展性:能够处理 PB 级数据集,适合大规模数据处理场景
易用性:无需长时间运行的服务,操作简单
支持多种数据格式:支持 Parquet 等常见数据格式的读写
强大的 SQL 支持:通过 SQL 语句实现复杂的数据处理逻辑
与 3FS 集成:支持分布式存储,提升数据处理效率
详细的文档支持:提供快速入门和 API 参考文档
使用教程
1. 安装 Smallpond:通过 pip install smallpond 安装
2. 初始化会话:使用 smallpond.init() 初始化会话
3. 加载数据:通过 smallpond.read_parquet() 加载数据文件
4. 数据处理:使用 smallpond.partial_sql() 执行 SQL 查询处理数据
5. 保存结果:将处理后的数据保存为 Parquet 格式
6. 查看结果:通过 df.to_pandas() 查看处理后的数据