Scala元组，操作地图数据
Scala元组是一种不可变的数据结构，它可以包含多个元素，每个元素可以是不同的类型。元组在Scala中被广泛用于操作地图数据，因为地图数据通常包含多个维度的信息。
优势：
- 灵活性：元组可以包含不同类型的元素，使得它们非常适合表示地图数据中的多个维度信息。
- 不可变性：元组是不可变的，这意味着一旦创建，其内容不能被修改。这有助于确保数据的一致性和安全性。
- 简洁性：使用元组可以减少代码的编写量，因为不需要为每个维度的信息定义单独的变量或类。
应用场景：
- 地理信息系统：元组可以用于表示地理坐标、地点名称、地点类型等信息。
- 数据分析：元组可以用于表示数据集中的多个维度，例如时间、地点、数值等。
- 物流管理：元组可以用于表示货物的起始地点、目的地点、货物类型等信息。
推荐的腾讯云相关产品和产品介绍链接地址：
- 腾讯云云服务器（CVM）：https://cloud.tencent.com/product/cvm 腾讯云云服务器提供高性能、可扩展的云计算资源，适用于各种规模的应用程序和工作负载。
- 腾讯云对象存储（COS）：https://cloud.tencent.com/product/cos 腾讯云对象存储是一种高可用、高可靠、低成本的云存储服务，适用于存储和管理大量的非结构化数据。
- 腾讯云人工智能（AI）：https://cloud.tencent.com/product/ai 腾讯云人工智能提供各种人工智能服务和工具，包括图像识别、语音识别、自然语言处理等，可用于处理和分析地图数据中的多媒体信息。
请注意，以上推荐的腾讯云产品仅供参考，具体选择应根据实际需求和项目要求进行评估。
相关·内容
我有一个应用程序，它必须先收集一些外部数据，然后将它们转换为对象。然后，对数据进行分析。
我设法收集了数据，并把它放到了地图上。该映射包含每个未来对象的唯一键，以及构建对象所需数据的ListBuffer。
现在我想从这个地图中创建一个对象列表，并且不知道如何从地图中获取数据。我以前没有使用过地图(是的，我对语言那么陌生)，但是我找到了，它说，当我想用head访问映射的一个元素时，我会得到一个键和值的元组。当我使用map (方法)迭代映射时，我希望得到同样的结果，但这似乎不起作用。我看了Scala的编程，但是当我在地图上迭代时，找不到一个地方说我得到了什么。
这是我想要做的事的MWE：
//Th
浏览 3提问于2014-06-20得票数 0
回答已采纳
例如，我有下表名为“示例”：
name | age | address
'abc' | 12 | {'street':'1', 'city':'kl', 'country':'malaysia'}
'cab' | 15 | {'street':'5', 'city':'jakarta&#
浏览 2提问于2015-04-16得票数 1
回答已采纳
我有一个地图的矢量如下，如何将它们转换成一个地图？
scala> (1 to 100).takeWhile(_<10).map{x=>val y=x+1;Map(x->y)}
res8: scala.collection.immutable.IndexedSeq[scala.collection.immutable.Map[Int,Int]] = Vector(Map(1 -> 2), Map(2 -> 3), Map(3 -> 4), Map(4 -> 5), Map(5 -> 6), Map(6 -> 7), Map(7 ->
浏览 3提问于2014-09-11得票数 0
回答已采纳
我有一张格式的地图
scala.collection.mutable.Map[String,List[(Int, Int, Int)]]
我希望能够访问独立的Int。地图中数据的格式总是
Mon-18-June-2018,1:10:5,2:20:10,3:30:15,4:40:20,5:50:25
其中日期是地图的键，每组三个数字的集合是(Int，Int，Int)
到目前为止，我已经能够以这种格式打印地图
Mon-18-June-2018
List((1,10,5), (2,20,10), (3,30,15), (4,40,20), (5,50,25))
使用以下代码
map.keys.for
浏览 0提问于2019-04-09得票数 3
回答已采纳
2回答
我在scala里有一个元组
val captainStuff = ("One", "Two", "Three", "Four", "Five")
我如何遍历for循环？？它很容易循环通过列表和地图。但是如何循环通过元组。
谢谢！！
浏览 4提问于2017-06-22得票数 3
回答已采纳
假设我有一张这样的地图：
scala> val a = Map("a"->2, "d" -> 4, "r" -> 5)
a: scala.collection.immutable.Map[String,Int] = Map(a -> 2, d -> 4, r -> 5)
我想动态地从这里移除多个键。当我能够做到这一点时：
scala> a - ("a","r")
res13: scala.collection.immutable.Map[String,Int] = M
浏览 2提问于2017-08-17得票数 7
回答已采纳
我在Scala中有一个可变的Map，它的定义如下：
scala> var sm = mutable.Map[String, mutable.Map[Int, Int]]()
sm: scala.collection.mutable.Map[String,scala.collection.mutable.Map[Int,Int]] = Map()
我有一个Map，它有另一个Map作为它的值&将值插入其中，如下所示。
scala> sm += ("abc" -> mutable.Map(1->0,0->0))
res77: scala.coll
浏览 1提问于2020-02-11得票数 0
1回答
嗨，我知道Scala提供了多种类型的映射，包括HashMap、TreeMap (我认为是Trie)、BitMap和ListMap。
因此，当您在scala中使用Map的基本要素(1 -> 2，2 -> 3)创建地图时，Scala选择使用哪种实现？我猜scala有一些规则可以从上面列出的映射类型中选择，但是这些规则是什么呢？显然，要使用散列，需要在某个地方定义某种散列策略。或者scala只是默认为其中一个实现？
谢谢
浏览 3提问于2017-08-27得票数 3
回答已采纳
3回答
我正在尝试使用map和reduce函数来计算两个向量之间的向量乘积。
让我们看看Scala的REPL中发生了什么：
首先，我定义了两个长度相同的向量
scala> val v1 = Array(1,4,5,2)
v1: Array[Int] = Array(1, 4, 5, 2)
scala> val v2 = Array (3,5,1,5)
v2: Array[Int] = Array(3, 5, 1, 5)
现在，我使用压缩函数创建了一个新的数组vecZip
scala> val vecZip = v1 zip v2
vecZip: Array[(Int, Int)]
浏览 1提问于2016-12-15得票数 2
1回答
我不知道如何解释/理解有关TreeSet和map函数的下列行为。
我想我漏掉了拼图里的一块。任何关于这件事的建议都会受到欢迎。
scala> class Person(val name: String, val age: Int) extends Ordered[Person]{
| def compare(that: Person) = {
| val nameComparison = name.compareToIgnoreCase(that.name)
| if(nameComparison != 0){
|
浏览 4提问于2014-09-26得票数 2
回答已采纳
声明如下：
将此可遍历集合映射转换为由这些可遍历集合的元素组成的映射。
我得到了“可穿越的收藏地图”例如，这将是一张列表地图。仅凭这个定义，Map[Int, List[Int]]就有资格了。
但是，“由这些可遍历集合的元素组成的地图”是什么呢？听起来很简单，但我很难让它开始工作。
文档中提供的示例代码是..。嗯..。我们可以说，不适用吗？
val xs = List( Set(1，2，3)，Set(1，2，3 ) .flatten // xs == List(1，2，3，1，2，3) val ys = Set(列表(1，2，3)，List(3，2，1) ).flatten // ys
浏览 1提问于2015-04-11得票数 6
回答已采纳
我正在尝试从结果集中获取一个名为-> id的映射。
val isp = SQL("select id, name from internet_service_providers").map { x => x[String]("name") -> x[String]("id") }
我无法理解为什么我会犯这个错误。
Exception in thread "main" java.lang.NoSuchMethodError: scala.Predef$.ArrowAssoc(Ljava/lang/Object;)L
浏览 3提问于2015-05-20得票数 0
回答已采纳
3回答
我有scala地图：
attrs: Map[String , String]
当我尝试像这样迭代map时；
attrs.foreach { key, value => }
上述方法不起作用。在每次迭代中，我必须知道键是什么，值是什么。使用scala语法糖迭代scala map的正确方法是什么？
浏览 1提问于2011-06-16得票数 84
回答已采纳
我有一个CSV文件，其中包含一个数据矩阵。该矩阵的第一列包含一个标签，其他列包含与标签关联的值(即与第一列关联)。现在我想读取这个CSV文件，并将数据放入Scala中的Map[String，ArrayString]中。Map的键应该是标签(在第一列中)，而Map值应该是其他值(这些值在其余列中)。要读取CSV文件，我使用opencsv。
val isr: InputStreamReader = new InputStreamReader(getClass.getResourceAsStream("test.csv"))`
val data: IndexedSeq[Array
浏览 0提问于2013-06-21得票数 3
我有一串列，它们是按用途、etc地址和个人信息分组的。val columns="address:addressLine,address:city,address:state,address:zipCode,person:firstName,person:lastName,person:middleName" 我希望它们是这样排列的： lastName->person,zipCode->address 因此，像lastName->person这样的每一对都是一张地图。我希望将这些地图放在另一个地图中，就像这样： columnSchema -> {
las
浏览 92提问于2021-04-30得票数 0
2回答
val numbers = scala.collection.parallel.mutable.ParTrieMap(
(1 until 100) zip (1 until 100): _*
) map { case (k, v) => (k.toDouble, v.toDouble) }
对于上面的代码，我知道(1 until 100) zip (1 until 100)将返回类似于地图的内容，但是_*跟在后面有什么意义呢？
浏览 1提问于2013-04-27得票数 0
回答已采纳
1回答
我对Scala还比较陌生，所以我对这种语言不是很有信心，我需要您的帮助来解决问题。我知道，理解只是一个语法糖，以简化复杂的地图/平面地图的层次结构。
现在，考虑有三个不同的范围间隔，这应该合并，以便创建所有可能的组合(尊重间隔)的值。
示例
使用“理解”，问题可以解决如下：
val intervalX = 1 to 5
val intervalY = 6 to 13
val intervalZ = 20 to 50
for {
x <- intervalX;
y <- intervalY;
z <- intervalZ
} yield (x,y,z)
Scala编
浏览 2提问于2017-12-08得票数 0
回答已采纳
1回答
问题1:我能用元组作为Scala地图的一个键吗？
问题2:如果是，我如何创建一个以元组为键的地图？
问题3:我想将我的scala映射转换为RDD，在下面的情况下我将如何做？我正试着这样做
变量mapRDD = sc.parallelize(map.toList)
这样做对吗？
问题4:对于这个特定的代码片段，当我在map上执行println时，它没有值。
我没有包括整个代码，基本上mapAgainstValue包含userId作为键，朋友列表作为值。我想用下面的键转换重新创建一个映射RDD。空地图的原因是什么？
var mapAgainstValue = logData
浏览 2提问于2016-10-22得票数 3
回答已采纳
2回答
我是Scala的初学者，使用lib "json4s“进行JSON解析，我的JSON数据格式如下：
scala> val str = """
| {
| "index_key": {
| "time":"12938473",
| "event_detail": {
| "event_name":"click",
| "location":"U
浏览 9提问于2015-07-05得票数 0
回答已采纳
scala的是如何工作的？它说，这是一个固定的时间向上看。
我认为ListMap必须遍历所有内容才能找到条目。为什么矢量地图会有所不同？
它是一个哈希表与一个向量相结合吗?在这个哈希表中，哈希表将把一个键映射到包含这些条目的向量中的索引中？
浏览 3提问于2021-06-19得票数 0
回答已采纳
1回答
为了与Play Framework一起使用Scala，我正在尝试学习Scala。现在我正在处理Scala + Slick数据库层的Play，我正在使用教程中的一段代码，我不理解它，也无法在Scala手册中找到任何信息。
事情是这样的。我有一个名叫Entry的模型。它被定义为case类，我有一个从Table扩展的同伴类。
case class Entry(id: Int, name: String)
class EntryTable(tag: Tag) extends Table[Entry](tag, "entries") {
def id = column[Int](&
浏览 3提问于2016-04-22得票数 6
1回答
我试图用Scala对日志数据执行一系列转换，并且在匹配元组时遇到了困难。我有一个包含用户I、urls和日期的数据框架。我可以将数据帧映射到RDD并使用此映射按键进行约简：
val countsRDD = usersUrlsDays.map { case Row(date:java.sql.Date, user_id:Long, url:String) => Tuple2(Tuple2(user_id, url), 1) }.rdd.reduceByKey(_+_)
这给了我一个RDD ((user_id，url)，计数)：
scala> countsRDD.take(1)
res9
浏览 2提问于2016-09-19得票数 0
回答已采纳
我需要使用scala创建每一行的地图，例如，
sunny,hot,high,FALSE,no
overcast,hot,high,FALSE,yes
rainy,mild,high,FALSE,yes
我要输出，
RDD[List(
Map(
'0 -> 'sunny,
'1 -> 'hot,
'2 -> 'high,
'3 -> 'false,
'4 -> 'no
),
Map(
'0 -> 'over
浏览 2提问于2014-11-15得票数 2
回答已采纳
我在地图下面
Object DataMapping
val myMap = Map(DataGroup.REAL-> SEQ(A,B,C),
DataGroup.PEAL-> SEQ(H,J,K,L,M),
DataGroup.CEAL-> SEQ(X,Y))
这个片段被用来在上面的地图上找到。很难理解_._2 and _._1在这段代码中做了什么，它的行为如何，以及它的输出是什么？
DataMapping.myMap.find(_._2.contains(Y)).map(_._1).get
我是scala
浏览 2提问于2022-07-27得票数 -1
1回答
我是新来的火花编程，我被困在使用地图。我的数据Rdd包含。
Array[(String, Int)] = Array((steve,5), (bill,4), (" amzon",6), (flikapr,7))
当我再次使用地图时，我得到了下面提到的错误。
data.map((k,v) => (k,v+1))
<console>:32: error: wrong number of parameters; expected = 1
data.map((k,v) => (k,v+1))
我试图传递一个带有键值的元组，并想要
浏览 0提问于2016-10-01得票数 0
回答已采纳
我想对一组对调用map()，但是我得到了一个类型不匹配错误。
例如，假设我想将Int对的列表映射到它们的和的列表：
scala> val ll=List((1,2),(3,4),(5,6))
ll: List[(Int, Int)] = List((1,2), (3,4), (5,6))
scala> ll.map((x:Int,y:Int)=>x+y)
<console>:9: error: type mismatch;
found : (Int, Int) => Int
required: ((Int, Int)) => ?
浏览 8提问于2012-10-16得票数 27
回答已采纳
我是很新的火花编程。我正在尝试将地图和reduceByKey实现到以下15个字段的数据集。
rdd=sc.parallelize([
("West", "Apple", 2.0, 10,2.0, 10,2.0, 10,2.0, 10,2.0, 10,2.0,2.0, 10),
("West", "Apple", 3.0, 10,2.0, 10,2.0, 10,2.0, 10,2.0, 10,2.0, 10,2.0])
这是我的map函数，在这里我试图创建一个包含多个键和值的元组。
rdd1 = rdd.map(lambda
浏览 1提问于2015-08-27得票数 1
嗨，我在play框架和scala方面很新，继续我正在阅读play文档，但是我在scala模板文件中打印地图中的索引时遇到了问题。我尝试了下面的代码，但它并不适用于我。
//尝试1:但不起作用
@(customer: Customer, orders: Seq[Order])
<h1>Welcome @customer.name!</h1>
<ul>
@orders.map { case(index,order) =>
<li>@index</li>
<li>@order.title</li>
浏览 2提问于2013-11-19得票数 0
回答已采纳
我的问题是：
for (something <- someotherthing) {
val m = in._2 // gets a scala.collection.mutable.Map[String, String] with already some values in it
if (someotherotherthing) {
m("item1") = "reset"
m("item3") = "reset"
}
something :+= m
}
浏览 3提问于2017-12-20得票数 1
回答已采纳
我正在考虑在clojure和scala之间进行一些互操作。由于java本身现在有lambdas，我在考虑数据之间的泛化以及如何将函数应用于集合。
构造函数扩展了clojure.lang.IFn和generalises在clojure.lang.ISeq上的集合操作
scala函数扩展了scala.Function和scala.collection.Traversable上的集合操作。
java扩展了java.util.function.Function，并在java.util.stream.Stream上扩展了集合操作。
问题：
在这种情况下，monads会有用吗？
浏览 0提问于2018-09-16得票数 7
回答已采纳
我正在尝试运行中给出的Spark / Python的Logistic回归示例，并且已经成功地使用了Spark1.6和Python2.7。
现在我必须将它移到Spark2.1和Python3.5( 3.6是不兼容的)，我正在使用Ubuntu16.04中的木星笔记本
这段代码工作正常
# Evaluate the model on training data
labelsAndPreds = modelInput.map(lambda p: (p.label, LRmodel.predict(p.features)))
print(labelsAndPreds.count())
print(lab
浏览 2提问于2017-04-12得票数 1
回答已采纳
4回答
我正在尝试使用Spark从HBase中流数据。当我运行scala脚本时，这是我得到的错误：
ERROR Executor: Exception in task 0.0 in stage 10.0 (TID 10)
java.io.NotSerializableException: org.apache.hadoop.hbase.io.ImmutableBytesWritable
起初，我认为我的数据格式不正确，所以我尝试创建一个只有一行的非常基本的表：
row1 column=fam1:c1, timestamp=1422306700801, value=abc
即使有了这一行，我仍然会遇到同
浏览 3提问于2015-01-26得票数 2
回答已采纳
1回答
我试图在星火应用程序中映射来自mongodb连接器的数据。在此之前，我没有其他错误，所以我假设到mongodb的连接是成功的。我使用以下代码来映射：
JavaRDD<AppLog> logs = documents.map(
new Function<Tuple2<Object, BSONObject>, AppLog>() {
public AppLog call(final Tuple2<Object, BSONObject> tuple) {
AppLog log = new AppLog();
浏览 5提问于2016-10-13得票数 1
回答已采纳
2回答
从R(完全新手)来到Scala。
假设我有两份清单：
val index = List(0,0,1,0,1)
val a = List(1,2,3,4,5)
然后，index可以定义一个从a到b: List[List[Int]]的自然地图：
1 -> b(0)
2 -> b(0)
3 -> b(1)
4 -> b(0)
5 -> b(1)
因此：
b = List(List(1,2,4), List(3,5))
通常，给定index和a，在Scala中创建b的最自然方式是什么？
例如，在R中，我可以写：
run_map <- function(i
浏览 0提问于2014-01-01得票数 2
回答已采纳
我有一个包含三列的DataFrame；如何将它转换为Scala - Array[Array[Double]]中的嵌套数组？
当我试图绘制地图时，我正在获取Array[(Double, Double)]：
val x= dataframe.select("time","sex")
.collect()
.map(x=>x(0).toString.toDouble ,x(1).toString.toDouble)
浏览 1提问于2017-02-01得票数 1
回答已采纳
我有两份名单
val a = List(1,2,3)
val b = List(5,6,7)
我想创建一个地图，如：
val h = Map(1->5, 2->6, 3->7)
基本上，通过列表和分配键值对进行迭代。
如何在Scala中正确地做到这一点？
浏览 5提问于2014-12-29得票数 1
回答已采纳
我正在Spark Scala上工作，需要将Map[String, String]保存到磁盘，以便其他Spark应用程序可以读取它。
(x,1),(y,2)...
要保存：
sc.parallelize(itemMap.toSeq).coalesce(1).saveAsTextFile(fileName)
我正在做一个合并，因为数据只有450行。
但要重新阅读它，我无法将其转换回Map[String, String]
val myMap = sc.textFile(fileName).zipWithUniqueId().collect.toMap
数据如下所示
((x,1),0),((y,2),
浏览 4提问于2018-09-01得票数 0
1回答
我尝试使用Map.map将映射转换为元组列表。但是，此操作失败了。我做了以下实验：
val m = Map(("a" -> 1), ("b" -> 2))
//> m : scala.collection.immutable.Map[String,Int] = Map(a -> 1, b -> 2)
val r1 = m.map{ case (k,v) => v} //> r1 : scala.collection.immutable.Iterable[Int]
浏览 0提问于2015-02-28得票数 17
回答已采纳
动机
这个问题是关于使用Scala中的数据列表，以及使用元组或类对象来保存数据。也许我的一些假设是错误的，所以就这样了。
我现在的方法
据我所知，元组不允许在提供的._1、._2等之外优雅地处理它们的元素。我可以使用它们，但是只要从定义它的代码行中提取数据，代码就会有些不愉快。
而且，正如我所理解的，Scala Map只能对其值使用单个类型声明，因此除了类型继承的情况外，它不能对其值的值类型进行多样化。(关于后一点，考虑使用Map值的类型层次结构“多样性”-除非类层次结构首先适合任何“模型”直觉，否则可能是非常人为的)。
因此，当我需要列出每个元素包含两个或多个命名数据实体的列表时(例如，在S
浏览 3提问于2014-09-27得票数 1
回答已采纳
我有RDD的数据，其中有4列，如地理，产品，时间和价格。我想计算基于geog和time的运行总和。
给定数据
我需要像这样的结果。
[
我需要这个spark-Scala-RDD。我是Scala领域的新手，我可以用SQL轻松实现这一点。我想在spark -Scala -RDD中这样做，就像使用(地图，平面地图)一样。
提前感谢您的帮助。
浏览 3提问于2017-01-11得票数 0
2回答
我正在尝试加载一个3列文件test.txt并从数据创建一个HashMap，其中第一列是键，第二列是值。下面是test.txt文件的样子：
afpoafi,oiqfj,qoifejpof
qopifjew,qofie,qowiefj
下面是我的代码及其产生的错误：
val invMapData = scala.io.Source.fromFile("/Users/Documents/test.txt")
val invLines = invMapData.getLines
var invMap = new HashMap[String,(String,String)]()
fo
浏览 4提问于2014-11-18得票数 1
回答已采纳
我试图分析以下Scala代码：
import java.nio.file._
import scala.Some
abstract class MyCustomDirectoryIterator[T](path:Path,someNumber:Int, anotherNum:Int) extends Iterator[T] {
def getCustomIterator(myPath:Path):Option[(DirectoryStream[Path],
Iterator[Path])] =
浏览 2提问于2015-03-31得票数 3
回答已采纳
1回答
我有一个卡夫卡的流媒体应用程序，我想知道是否有办法从地图函数中进行范围查询？
我将来自kafka的信息按时间范围和键分组，然后根据这些时间范围和键，我想将cassandra中的数据提取到dstream中。
类似于：
lookups
.map(lookup => ((lookup.key, lookup.startTime, lookup.endTime), lookup))
.groupByKey()
.transform(rdd => {
val cassandraSQLContext = new CassandraSQLContext(rdd.context
浏览 2提问于2016-07-14得票数 3
回答已采纳
2回答
嗨，我有以下数据，并希望将其映射到第二个参数中的第一个项。因此：
1 -> List((1,11))
1 -> List((1,1), (1,111))
我要：
(1,11)
(1,1)
当该数据位于RDD中时，我可以执行以下操作：
scala> val m = sc.parallelize(Seq(11 -> List((1,11)), 1 -> List((1,1),(1,111))))
m: org.apache.spark.rdd.RDD[(Int, List[(Int, Int)])] = ParallelCollectionRDD[198] at pa
浏览 11提问于2017-06-05得票数 0
回答已采纳
总的来说，我对Scala和函数式方法相当陌生。我有一张地图，看起来像这样：
val myMap: Map[String, List[Int]]
我想结束一些将键映射到关联列表总数的东西：
val totalsMap: Map[String, Int]
我最初的预感是用a来理解：
val totalsMap = for (kvPair <- myMap) {
kvPair._2.foldLeft(0)(_+_)
}
但是，我不知道我会把什么放在产生()子句中，以便从理解图中得到一张地图。
浏览 0提问于2014-09-02得票数 2
回答已采纳
scala> val two = (1,2)
two: (Int, Int) = (1,2)
scala> val one = (1,)
<console>:1: error: illegal start of simple expression
val one = (1,)
^
scala> val zero = ()
zero: Unit = ()
是这样的吗：
val one = Tuple1(5)
在Scala中编写单例元组文字的最简洁方法是什么？Unit是否像一个空元组一样工作？
这种不一致会让其
浏览 4提问于2011-08-27得票数 25
回答已采纳
1回答
当我预先定义一个元组+=并将其添加到一个映射中时，我不明白为什么mapEntry会工作，同时试图直接添加，而绕过创建不必要的变量mapEntry失败。很可能我漏掉了一些显而易见的东西。提前谢谢。
这是有用的: map += mapEntry，而这失败了: map += (“键到汤姆”，Person(“汤姆”，“马克思”))
以下是我完整的scala会话
Welcome to Scala version 2.10.3 (Java HotSpot(TM) 64-Bit Server VM, Java 1.7.0_45).
Type in expressions to have them evalu
浏览 2提问于2013-11-16得票数 1
回答已采纳
我在Spark集群上使用h2o模型( mojo格式)时遇到了问题，但只有当我尝试并行运行它时，而不是当我使用collect并在驱动程序上运行它时。
由于我预测的数据帧具有超过100个特征，因此我使用以下函数将数据帧行转换为h2o的RowData格式(来自)：
def rowToRowData(df: DataFrame, row: Row): RowData = {
val rowAsMap = row.getValuesMap[Any](df.schema.fieldNames)
val rowData = rowAsMap.foldLeft(new RowData()) { cas
浏览 1提问于2018-01-03得票数 0
2回答
我已经注意到Scala中的这种行为
val list = List[(Int, Int)]()
val set = HashSet[(Int, Int)]()
scala> list :+ (1, 2)
res30: List[(Int, Int)] = List((1,2))
scala> list :+ (1 -> 2)
res31: List[(Int, Int)] = List((1,2))
scala> list :+ 1 -> 2
res32: List[(Int, Int)] = List((1,2))
//Work
// But the s
浏览 0提问于2020-04-18得票数 3
1回答
我有一个函数map，它接受一个Parser和一个定义如下的函数：
def map[T1, T2](parser: Parser[T1], func: T1 => T2): Parser[T2]
我已经创建了一个类型为Parser的[(Char, Char)]对象和一个函数(Char, Char) => String。
val parser[(Char,Char)] = //...
val asString: (Char, Char) => String = (a: Char, b: Char) => a.toString + b.toString
然后将这两个函数传递给
浏览 2提问于2018-07-20得票数 4
回答已采纳
扫码
添加站长 进交流群
领取专属 10元无门槛券
手把手带您无忧上云
相关资讯
热门标签
云服务器
ICP备案
实时音视频
对象存储
即时通信 IM活动推荐
腾讯云开发者
