我是scala spark的新手。这里我有一个单词计数程序，其中我将输入文件作为参数传递，而不是硬编码并读取它。我不知道如何将文件名(在代码中)作为参数传递到我的主类中import org.apache.spark.SparkConf w.collect.foreach(println)
浏览 15提问于2019-07-28得票数 0
1回答
在PySpark中，如何将Dataframe转换为普通字符串？我将PySpark与Kafka一起使用，而不是硬编码代理名称，而是在PySpark中参数化了Kafka broker名称。Json文件保存了代理详细信息，Spark读取这个Json输入并将值赋值给变量。这些变量为带有字符串的Dataframe类型。当我将dataframe传递给Pyspark连接细节以替换值时，我将面临问题。只能将字符串(不是Dataframe)连接到字符串。kafka.bootstrap.
浏览 0提问于2021-03-05得票数 0
假设我们有一个现有类型T的变量函数void foo(T args...)。在Java (void foo(T... args))和C# (void foo(params T[] args))中，传递T类型的数组T[]是将其内容作为参数传递给foo的有效方法。在Scala (def foo(args: T*): Unit)中，我可能会传递一个Seq[T]。
如何将容器的内容(数组、向量、迭代器等)作为
浏览 11提问于2018-08-07得票数 1
回答已采纳
4回答
到目前为止，我的主要方法是：但是，当我转到命令并编写：我得到以下内容: error found : String error required: scala.xml.Elem error val : scala.xml.Elem= args(0)
另外，我并不是在寻找像作用域这样的解析器，我只是想将文件传递</em
浏览 9提问于2014-07-14得票数 0
回答已采纳
我需要从命令行向scala程序传递多个参数。第一个是数据库，第二个是表，第三个是映射，其中map可以有从1到n的组合(String，Int)。然后执行我的脚本，如下所示：
如何将此Map传递给脚本中的字段变量
浏览 3提问于2017-06-17得票数 0
回答已采纳
fieldList) { System.out.println(fieldList[i]); } def main(args: Array[String]) {}
如前所述，我想调用一个用java编写并具有非固定参数的方法。当我在scala中传递参数时，fieldList.length总是1，只需要得到整个args，
浏览 0提问于2017-03-14得票数 0
回答已采纳
5回答
我有一个Scala数据处理工具，它由于java.lang.OutOfMemoryError异常而失败。该工具需要对一个大型数据文件进行多次遍历(我正在处理的文件超过700MB)，所以如果整个数据文件都可以存储在内存中会很方便。
我使用"scala“运行器从命令行或从Bash脚本运行该工具。我尝试过传递-Xmx1024m，但是它不能识别这个参数。我使用的是Scala2.8.0 (r18678)的夜间构建。
浏览 2提问于2009-09-17得票数 53
回答已采纳
我有一个java构造函数，它将函数接口作为参数： super(queue);}我还尝试在运行时转换该函数--但
浏览 2提问于2016-07-19得票数 7
回答已采纳
如何将所有3条命令行的内容传递给我的NSIS编译的变量中的exe，以便我可以使用这些参数来Exec(ute)另一个exe。例如- start abc.exe "test.txt" "-1"是传递给我的NSIS编译的exe的命令，其中"abc“是exe名称，"test.txt”和"
浏览 2提问于2013-12-10得票数 0
回答已采纳
2回答
我已经将一个变量组链接到我的构建管道。变量组中有一个变量。我正尝试在我的管道中的bash脚本中使用该变量。
但是，$TESTING_YOLO不起作用。我花了2个小时尝试从bash脚本引用这个变量。我真的不知道该怎么做。
浏览 17提问于2018-08-24得票数 3
回答已采纳
我可以将变量作为多值参数进行传递：res26: scala.xml.Elem = <b></b>
res27: scala.xml.Elem = <a><b></b></a>
但我不能将XML文本作为多值<
浏览 0提问于2011-09-26得票数 6
回答已采纳
5回答
在我的程序的main方法中，我有一堆扫描器输入，我已经使用参数将它们传递给了各种方法。在这些不同的方法中，我进行了计算，创建了新的变量。在我的最后一个方法中，我需要将这些新变量加在一起，但是编译器不会识别这些新变量，因为它们只存在于其他方法中。我该如何将新变量传递给我的最终方法呢？
浏览 0提问于2013-10-01得票数 0
假设我有一个函数abc()，它将处理与分析传递给我的脚本的参数相关的逻辑。abc $1 $2 $3 $4
更好的是，我的函数是否可以访问脚本参数<e
浏览 7提问于2010-09-28得票数 879
回答已采纳
因此，根据一个众所周知的火花bug/设计限制，您不能有多个SparkContexts。现在，我对python和Scala进行了非常糟糕的混合，并且我有一个Scala方法，它需要一个SparkContext作为参数。我可以以某种方式在py4j中实例化这个Scala对象，然后传递它的SparkContext (作为sc导出)。我的理解是，sc是Scala对象的一个薄包装器，但我不知道如
浏览 5提问于2016-06-14得票数 1
回答已采纳
1回答
我想将env配置变量process.env.config.myVar传递给我的nuxt-链接，如下所示： name: 'search-page', process.env.config.myVar['process.env.config.myVar']: { query: `${searchValue}` }}"
但是它打印整个process.env.config.myVar作为参数还尝试
浏览 0提问于2021-07-06得票数 1
回答已采纳
1回答
我的docker-compose.yml文件如下所示：services:
networks: ....networks:我的主程序是一个scala应用程序，它需要Redis & ActiveMq的IP，我如何将这些服务的IP传递给我的主应用程序
浏览 2提问于2017-03-30得票数 2
回答已采纳
3回答
5,9,5,2,1,3))) println(passedRanks(5,9,5,2,1,3))}
该示例来自于com.agical.gsl，它是swt的scala我猜想它在Scala2.8之前就使用了scala特性。此错误为too many arguments for method apply: (v1: Seq[Int])Seq[Int] in trait Function1，并与变量参数</em
浏览 2提问于2016-05-30得票数 2
回答已采纳
扫码
添加站长 进交流群
领取专属 10元无门槛券
手把手带您无忧上云
相关资讯
热门标签
云服务器
ICP备案
腾讯会议
云直播
对象存储活动推荐
腾讯云开发者
