AzureDatabricks根据配置以不同方式处理文件
创始人
2024-11-19 15:00:37
0

考虑以下代码示例,其中我们在创建 Databricks 集群时将 spark.sql.files.maxPartitionBytes 配置为不同的值,来观察文件处理方式的差异:

from pyspark.sql.functions import *
from pyspark.sql.types import *

# Read a sample CSV file
df = spark.read.format("csv") \
  .option("header", True) \
  .option("inferSchema", True) \
  .load("dbfs:/path/to/sample.csv")

# Configuration 1
spark.conf.set("spark.sql.files.maxPartitionBytes", "128mb")
df.write.format("csv") \
  .mode("overwrite") \
  .option("header", True) \
  .option("compression", "gzip") \
  .save("dbfs:/path/to/output_128mb/")

# Configuration 2
spark.conf.set("spark.sql.files.maxPartitionBytes", "64mb")
df.write.format("csv") \
  .mode("overwrite") \
  .option("header", True) \
  .option("compression", "gzip") \
  .save("dbfs:/path/to/output_64mb/")

在上述代码示例中,我们首先读取一个 CSV 文件,并接着将 spark.sql.files.maxPartitionBytes 配置为 128mb, 将文件使用 gzip 压缩格式写入 Databricks 文件系统的指定路径。接着,我们将同样的文件使用另外一种配置(64mb)再次写入 Databricks 文件系统的另一个路径。

我们可以通过使用以下命令来检查写入文件的大小以比较它们之间的差异:

import os

def print_file_size(path):
  file_size = os.path.getsize("/dbfs" + path)/1024/1024
  print(f"Size of {path} - {round(file_size, 2)} MB")
  
print_file_size("/path/to/output_128mb/")
print_file_size("/path/to/output_64mb/")

我们可以观察到,使用 64mb

相关内容

热门资讯

6分钟辅助!hhpoker是真... 6分钟辅助!hhpoker是真的假的,hhpoker真的有透视吗,演示教程(真是有挂)1、每一步都需...
第七分钟辅助!we poker... 第七分钟辅助!we poker插件,we poker免费辅助器,手筋教程(有挂方式)暗藏猫腻,小编详...
七分钟辅助!aa poker辅... 七分钟辅助!aa poker辅助包,pokemmo脚本辅助器下载,讲义教程(有挂秘籍)1、pokem...
第四分钟辅助!wepoker辅... 第四分钟辅助!wepoker辅助器安装包定制,aapoker透视脚本,大纲教程(有挂总结)所有人都在...
第四分钟辅助!wpk透视辅助靠... 第四分钟辅助!wpk透视辅助靠谱吗,wepoker透视苹果系统,诀窍教程(有挂猫腻);运wepoke...
七分钟辅助!aapoker透视... 七分钟辅助!aapoker透视脚本入口,wejoker开挂,学习教程(有挂教程)1、打开软件启动之后...
第四分钟辅助!淘宝买wepok... 第四分钟辅助!淘宝买wepoker透视有用吗,wpk俱乐部怎么作弊,积累教程(有挂规律)1、下载好淘...
6分钟辅助!we-poker软... 6分钟辅助!we-poker软件,购买的wpk辅助在哪里下载,积累教程(有挂技巧)购买的wpk辅助在...
第2分钟辅助!如何下载wepo... 第2分钟辅助!如何下载wepoker安装包,newpoker怎么安装脚本,教程书教程(今日头条)1、...
4分钟辅助!wepoker钻石... 4分钟辅助!wepoker钻石怎么看底牌,wepoker辅助器有哪些功能,法门教程(有挂详细)该软件...