如何在 Python 3 pyspark 中反转 RDD 中的键和值?

2023-12-02

这在 Python 2.7 中有效,但在 Python 3.5 中它返回

语法错误:语法无效。

我不确定这是否与我在另一篇文章中读到的“元组解包”从 Python 3 中删除这一事实有关,或者是一个不同的问题。

rddInverted = rdd.map(lambda (x,y): (y,x))

尝试这样的事情:

rddInverted = rdd.map(lambda x: (x[1], x[0]))

我希望它能起作用

本文内容由网友自发贡献,版权归原作者所有,本站不承担相应法律责任。如您发现有涉嫌抄袭侵权的内容,请联系:hwhale#tublm.com(使用前将#替换为@)

如何在 Python 3 pyspark 中反转 RDD 中的键和值? 的相关文章

随机推荐

  • 在 C++ 中使用无符号变量的真正优势是什么? [复制]

    这个问题在这里已经有答案了 所以我明白了unsigned变量只能保存正值并且signed变量可以为负值和正值 但是 我不清楚为什么有人会使用unsigned变量 那不是有风险吗 我的意思是我个人会坚持signed变量以防万一 使用是否有内存
  • 分布式Erlang发送大消息有哪些性能特点?

    假设我在 Erlang 应用程序中创建新的本地进程 并且我想向它发送一条大消息 module chain hello start N Some big data gt Pid1 spawn chain hello some fun N Pi
  • 如何将变量的数字或值分配给 Fortran77/90 中的字符

    假设我使用实数变量 x 我想指定为一个字符 以便我可以根据 do 循环中 x 的值使用它来打印不同的文件名 我现在的代码是 program test print real 8 x character 40 chr x x 1 d0 do i
  • Firebase java对象序列化和继承[重复]

    这个问题在这里已经有答案了 它也序列化继承的属性吗 IgnoreExtraProperties public class Item extend BaseObservable private String foo public Item B
  • 无效的列名称“USER_SOURCE”

    我有一个存储过程 它以 xml 形式返回结果 Data输出参数 在xml代码中分配数据是 SELECT data SELECT DISTINCT CONVERT varchar 2 u USER SOURCE CONVERT varchar
  • 黑莓 - 自定义 BubbleChartField

    我需要开发一个应该显示气泡图的黑莓应用程序 如何实现这个目的的自定义控件 thanks UPDATE这是知识库如何 创建图形字段 你的问题应该更具体 更完整 好吧 只是为了给你指明方向 public class BubbleChart ex
  • Weka 从命令行预测到 CSV

    这与这个问题类似 Weka 对 CSV 的预测 但是从命令行 我有以下 Weka 命令 java Xmx10G weka classifiers meta FilteredClassifier t test data arff d pred
  • d3 v4:合并输入和更新选择以删除重复代码

    我明白那个merge可用于组合 d3 v4 中的输入和更新选择 如以下简单示例所示 https bl ocks org mbostock 3808218 我有一个散点图 其中多个变量显示在共享 x 轴上 用于下拉框选择的不同组 选择新组时
  • 即使每个更改的文件都与父文件之一一致,如何“git show”具有组合差异输出的合并提交?

    进行 简单 合并 没有冲突 后 git show通常只显示类似的内容 commit 0e1329e551a5700614a2a34d8101e92fd9f2cad6 HEAD master Merge fc17405 ee2de56 Aut
  • 在 Inno Setup 中使用 rundll32 或 dpinst 安装驱动程序?

    我正在尝试使用 Inno Setup 安装驱动程序 看起来有 至少 两种方法可以做到这一点 dpinst exe或运行rundll反对这 inf file 我知道有两个不同版本的 DPinst 适用于 x86 和 x64 根据操作系统的不同
  • 范围生成中“..”(双点)和“...”(三点)之间的区别?

    我刚刚开始学习 Ruby 和 Ruby on Rails 遇到了使用范围的验证代码 validates inclusion of age in gt 21 99 validates exclusion of age in gt 0 21 m
  • C++ 在什么条件下优化构造函数调用?

    我正在为矩阵算术编写一个类 我正在实现的一个功能是您可以 切片 一个矩阵并返回另一个矩阵 但这样做是为了使返回的矩阵引用父级的内存 如果您想要获取矩阵的一部分或将向量添加到列或类似的事情 这非常有用 但是 我想实现它 以便如果分配或复制返回
  • 为矩阵的每一行设置特定列的值

    我有一个矩阵A with m行 我想将每行的特定元素设置为 1 列索引因行而异 由列向量指定a with m值 也就是说 我想要A i a i 1 有没有一种快速的方法可以在Matlab中做到这一点 没有for循环 我用以下方法解决了这个问
  • Python urllib2.open 连接被对等错误重置

    我正在尝试使用 python 抓取页面 问题是 我不断收到 Errno54 连接被同行重置 当我运行此代码时出现错误 urllib2 urlopen http www bkstr com webapp wcs stores servlet
  • 计算两个经纬度点之间的距离? (半正矢公式)

    如何计算由纬度和经度指定的两点之间的距离 为了澄清起见 我想要以公里为单位的距离 这些点使用 WGS84 系统 我想了解可用方法的相对精度 This link可能对您有帮助 因为它详细介绍了半正矢公式来计算距离 Excerpt 该脚本 Ja
  • SQL Server 表填充源

    我有一个审计数据库 由其他人创建 有些东西正在用表大小数据填充它 这很有意义 因为它是审计数据库 SQL 服务器有太多的工作 我想知道审计表中填充了什么 有没有像 sys comments 之类的东西 它可以告诉我什么正在填充表 或者我是否
  • Google App Script 背景通过 HtmlService 透明

    我正在为 google 网站使用 google apps 脚本 并且我可以使用以下命令轻松创建透明背景UiApp createApplication setStyleAttribute background transparent 现在 我
  • 将 NuGet 包替换为本地 dll 文件

    我正在开发的项目依赖于 NuGet 包 包内的dll文件是在Release模式下编译的 因此使用调试器检查代码 这是我的目标 是不可能的 我想用我在调试模式下编译的文件替换 dll 文件 如果我通过 NuGet 删除包然后通过添加它Add
  • Paradox 如何管理 null 值和空值?

    我通过 Borland 数据库引擎 BDE 使用 Paradox 表 我无法领悟道路null and 空字符串值在字符串字段中处理 Paradox 数据类型 A 我的具体问题是如何确定字段值是否为空或空字符串 在数据库桌面工具中 它们似乎都
  • 如何在 Python 3 pyspark 中反转 RDD 中的键和值?

    这在 Python 2 7 中有效 但在 Python 3 5 中它返回 语法错误 语法无效 我不确定这是否与我在另一篇文章中读到的 元组解包 从 Python 3 中删除这一事实有关 或者是一个不同的问题 rddInverted rdd