英文: Parallelize an operation applied to a list (PySpark) 问题 在我的程序中的某一点，一个函数接收一个列表并对其中的每个项执行操作。 举例来说，...
70评论pyspark
python
如何将数据框传递给不同的函数，并进行筛选和分组。
英文: How to pass dataframe to different functions with filters and group by 问题 我有一个来自pyspark查询的数据框架。但...
75评论apache-spark
python
如何在pyspark数组中获取第一个带有数字的字符串值。
英文: How to get first string value with numbers in pyspark array 问题 I want to extract just the first ...
62评论apache-spark
pyspark
Snowpark表格创建失败，即使查询成功执行。
英文: Snowpark table creation failing even query executed successfully 问题 我正在尝试在Snowpark中使用参数化值从另一个表创建...
65评论apache-spark
pyspark
pySpark性能问题 – 反复查询原始数据
英文: pySpark performance issue - repeatedly query rawdata 问题 I'm using pySpark to query a large data ...
55评论pyspark
query-optimization
使用pyspark，我可以写入我没有GetObject权限的S3路径吗？
英文: using pyspark can I write to s3 path I don't have GetObject permission to? 问题 在Spark完成将数据帧写入...
63评论amazon-web-services
apache-spark
Spark Barrier Executor Stage Not Retried on Task Failure
英文: Spark Barrier Executor Stage Not Retried on Task Failure 问题 使用障碍执行器运行阶段时，期望任务失败会导致阶段重试。然而，如果任务引发...
68评论apache-spark
python
将巨大的CSV文件拆分成多个文件，使用Python。
如何提高雪地公园程序的性能？
英文: How to improve the performance in snowpark procedure? 问题 以下是您提供的代码的中文翻译部分： 我有以下用于根据特定键合并和截断表格的过程...
56评论apache-spark
python-3.x
org.apache.kafka.common.KafkaException: 构建 Kafka 生产者失败
英文: org.apache.kafka.common.KafkaException: Failed to construct kafka producer 问题 我有一个docker-compose...
100评论apache-kafka
python
38