我有一个值为Tuple4的ListMap： "con1" -> ("str 1", "str 2", "str 3", true))
/*line A*/def testAllCon(map: ListMap[String, Tuple4[String,String, String, Boolean]]): Unit = {map.ge
浏览 9提问于2017-06-25得票数 0
1回答
我正试图将一个CSV文件映射到一个Tuple4中，该文件已经由Flink消费，由Kafka生产。我的CSV文件有4列，我想将每一行映射到一个Tuple4中。问题是我不知道如何实现map()和csv2Tuple函数。这就是我被困的地方：
StreamExecutionEnvironment env = StreamExecutionEnvironment.getExecutionEnvironment
浏览 0提问于2018-08-25得票数 0
回答已采纳
2回答
我有一个关于apache和Java的问题现在，我使用一些映射函数来获得如下内容：(这是随机测试数据的问题是：
浏览 2提问于2015-12-09得票数 0
回答已采纳
我有一个具有四个值的JavaRDD元组：我想按双值降序对元组进行排序5.1, 7, 10) (7, 4.3, 5, 9) (8, 1.2, 4, 7)
到目前为止，我已经尝试使用这样的自定义，我需要使用sortByKey函数。(因为正常<
浏览 2提问于2017-06-18得票数 2
回答已采纳
2回答
我是scala的新手。 val salesdata = sc.textFile("hdfs://localhost:9000/home/jayshree/sales.csv")2.在对每个商品应用30%折扣后，找出客户明
浏览 0提问于2017-03-23得票数 1
我有一个返回List<String[]>的函数，我可以修改它以返回其他东西，在规模上，我调用的函数期望输入为：Seq[Product][scalac-2.11] found :List[Array[String]]我是scala的新手，我怎样才能做到同样的事情呢？我需要调用的api期望输入如下所示：
Seq( ("id&quo
浏览 31提问于2018-08-29得票数 1
回答已采纳
我正在学习spark streaming，并从一些生产日志中找出一些散列标签。在一些示例中，我发现了以下代码： val words = statuses.flatMap(line => line.split(" "))
val tags = words.filter(w =>但是我不明白这个reduceByKeyAndWindow在这里是如何工作的？为什么我们要递减第二个参数中的值呢？
浏览 29提问于2019-03-17得票数 0
这个值位于一个csv文件中，但是我真的不知道如何让它工作。下面是我的映射csv文件：9002;10{"bookingId":"8", "eventAction":"start", "eventType":Float>(second.f1, first.f1, first.f2, first.f3);
浏览 4提问于2017-07-20得票数 2
在GoLang中，如果一个函数接受相同类型的多个参数，您可以将其键入如下： return x + y其中x和y均为int型。但是，我无法确定scala是否存在这样的速记符号。我试过跟随，但没有结果。对于一个简单的例子来说，这并不是什么负担。但是对于我想出的一些案例类，这看起来非常冗长，与scala关于冗长的立场相冲突
浏览 1提问于2015-10-05得票数 0
回答已采纳
我只是比较一下如何在java中序列化对象和从JSON序列化对象。jsonInString = "{'name' : 'john smith'}";
使用Playframework和Scala，我必须创建这些读写映射器，它们非常冗长。我有我的模型，我想简单地读&#x
浏览 3提问于2015-11-09得票数 1
1回答
我的数据集如下：---------1,2005,A,32,2005,A,41,2005,2,9编辑 JavaRDD<String> csv = spark.read().texfile("path.csv").JavaPairRDD<String , Tuple2<Long, S
浏览 3提问于2020-05-07得票数 0
回答已采纳
我正在尝试在Scala中为代数半环建模。我遇到了类型转换问题，这使得我无法在Scala中做我想做的事情。我希望有人能带我到我误解的Scala类型系统方面。半环是一组项目，在这些项目上定义了二元加法(+)和乘法(*)运算符及其单位元素，分别称为0和1。我希望能够编写与半环元素一起工作的算法。我使用</e
浏览 1提问于2012-10-03得票数 3
回答已采纳
3回答
这个问题出现在的“地图和元组”一章中。
// source file: https://www.gutenberg.org/cache/epub/35709/pg35709.txt
scala> val words = scal
浏览 0提问于2015-08-20得票数 3
回答已采纳
我在Scala中有以下映射：m += 1 -> Set(1)我发现最后一行不起作用。我得到“错误:重新分配给val”。所以我试着s += 2
然后，当我在添加2之后比较m(1)和s时，它们的内容是不同的。那么，如何将一个元素添加到一个集合中，该集合是一个映射的值？我有Java/C++背景，所以我尝试的</
浏览 0提问于2011-08-22得票数 3
回答已采纳
2回答
一个是scala，另一个是java。Java文件希望使用该映射作为字典。
我是scala和java的新手。我如何才能将scala映射转换为java dici流呢？
浏览 5提问于2014-02-01得票数 5
回答已采纳
2回答
馆藏功能方法
、、、、
我正在学习Scala，并且对集合中可用的所有方法(高阶函数)感到有点困惑。哪一个比最初的集合产生更多的结果，哪一个产生的更少，哪一个最适合于给定的问题？虽然我正在学习Scala，但我认为这涉及到大多数现代功能语言(Clojure，Haskell)和Java 8，Java 8在Java集合中引入了这些方法。具体来说，现在我想知道如何使用过滤器映射，
浏览 0提问于2012-11-02得票数 6
回答已采纳
3回答
背景：我发现使用TypeTags或TypeClasses可以处理这个问题，这是很棒的。但是，与其一
浏览 0提问于2015-08-28得票数 3
回答已采纳
2回答
我发现自己使用了很多嵌套的映射，例如Map[Int，Map[String，SetString]]，并且我希望在访问新密钥时自动创建新的映射、集等。例如，类似于下面的内容：m(1992)("foo") += "bar"
请注意，如果没有必要，我不想在这里使用getOrElseUpdate，因为当您有嵌套的映射时，它会变得非常冗长，并且模糊了代码中实际发生
浏览 0提问于2010-07-06得票数 8
回答已采纳
7回答
我一直在寻找，但我找不到一个我能理解的关于Scala中aggregate函数的例子或讨论。它看起来很强大。Seq(("one" -> Seq("i","1")), ("two" -> Seq("2", &q
浏览 2提问于2011-08-03得票数 36
回答已采纳
我最近开始学习Scala，并尝试使用Java中的Scala代码。导入的jar文件可以工作，并包含我的类和方法；然而，当我发现在可用于导入的类中，我可以同时访问DiceRoller和DiceRoller$，并且还可以在普通类中访问attribute_$eq等方法，我感到有点惊讶DiceRoller在Scala中被定义为对象，其余的类被定义为类，如果
浏览 0提问于2015-06-07得票数 5
回答已采纳
扫码
添加站长 进交流群
领取专属 10元无门槛券
手把手带您无忧上云
相关资讯
热门标签
云服务器
ICP备案
腾讯会议
云直播
对象存储活动推荐
腾讯云开发者
