scala - Spark 壳 : How to copy multiline inside?

标签 scala apache-spark spark-shell

我有一个要使用 Spark shell 执行的 Scala 程序,现在当我将粘贴复制到 spark shell 时它不起作用,我必须在里面逐行复制。

我应该如何复制shell中的所有程序?

谢谢。

最佳答案

在 spark-shell 中,你只需要使用命令“:paste”

scala> :paste
// Entering paste mode (ctrl-D to finish)

val empsalary = Seq(
  Salary("sales", 1, 5000),
  Salary("personnel", 2, 3900),
  Salary("sales", 3, 4800),
  Salary("sales", 4, 4800),
  Salary("personnel", 5, 3500),
  Salary("develop", 7, 4200),
  Salary("develop", 8, 6000),
  Salary("develop", 9, 4500),
  Salary("develop", 10, 5200),
  Salary("develop", 11, 5200))
.toDS.toDF


然后使用 ctrl-D 退出此模式。你可以看到输出:
// Exiting paste mode, now interpreting.

empsalary: org.apache.spark.sql.DataFrame = [depName: string, empNo: bigint ... 1 more field]

关于scala - Spark 壳 : How to copy multiline inside?,我们在Stack Overflow上找到一个类似的问题: https://stackoverflow.com/questions/58008829/

相关文章:

apache-spark - 使用 utf-8 字符编码从 hive 中选择数据

scala - 找不到 Apache Spark 方法 sun.nio.ch.DirectBuffer.cleaner()Lsun/misc/Cleaner;

linux - 由于转义字符导致找不到文件错误

scala - Play (Scala)、Reactivemongo 和多个数据库

Scala 子字符串正确抛出 IndexOutOfBounds,但在 Scala.js 中不会

scala - Tachyon on Dataproc Master 复制错误

java - Java 的 Spark 示例字数统计执行失败

Scala如何通过模式获取LocalDate

scala - 为什么 Scala 程序应该有一个 main 方法或扩展 App trait?

dataframe - Spark Dataframe.cache() 更改源的行为