scala

0热度

1回答

我有以下的输入字符串 "/horses/[email protected]" "/Goats/[email protected]" "/CATS/[email protected]" 我想获得 "horses", "c132", "[email protected]" "Goats", "b-01", "[email protected]" "CATS", "001", "[email

4热度

2回答

案例类toString与Iterable特征纠缠？

看起来，如果案例类延伸Iterable[T]，则toString方法发生更改。 case class MyPoint(x: Int, y: Int) case class MyOtherPoint(x: Int, y: Int) extends Iterable[Double] { def iterator: Iterator[Double] = Iterator.fill(4)(1

0热度

1回答

使用Flink和基于事件时间的流计算平均值

我想在基于历史事件的流中计算Flink中基于窗口的平均值（或由我定义的任何其他函数），因此流必须是事件时间（不处理基于时间）： val env: StreamExecutionEnvironment = StreamExecutionEnvironment.getExecutionEnvironment env.setStreamTimeCharacteristic(TimeCharacteri

0热度

1回答

Spark可以直接将数据读入嵌套的case类吗？

假设您有一个包含三列的CSV：item,username和userid。它是利用星火的数据集API在读这一个相当简单的事情： case class Flat(item: String, username: String, userid: String) ds = sparkSession.read.csv("path/to/data").toDF("item", "username", "use

-2热度

2回答

如何在部分函数中使用一个常量整数作为输入？

我新的阶，我其中我要定义一个局部函数来添加三个数字，其中一个数量是恒定的和两个数字可以作为输入被传递，并定义可采取局部的另一种方法的使用情况作为输入并给出其立方体作为结果。

1热度

1回答

Akka Streams KillSwitch在alpakka jms

我有一个场景，我开始使用alpakka多个jmsSource（对于不同的队列）。我还需要在任何时候卸下队列。所以我已经添加KillSwitch到jms阿卡流，如下所示： - trait MessageListener { lazy val jmsPipeline = jmsSource .map { x => log.info(s"Received message ${x}

0热度

1回答

星火群组rdd由配对RDD上的钥匙和群组组成，并从每个群组中挑选最新的

Spark和Scala的新手。试图达到以下。我的消息看起来像以下（钥匙，ID，版本，dataObject时） val transformedRDD = processedMessages.flatMap(message => { message.isProcessed match { case true => Some(message.key, message.id, mes

0热度

1回答

集团由多到多用鹅毛笔

加入我试图用鹅毛笔要达到什么下面PostgreSQL的查询做： select books.*, array_agg(authors.name) from books join authors_books on(books.id = authors_books.book_id) join authors on(authors.id = authors_books.author_id) gro

0热度

1回答

雀科：我怎么能在中间定义端点与参数

我想在中间定义一个端点与参数。 GET（ “富” ::参数（ “ID”）:: “咕”）所以，我可以用下面的REST调用叫它：类似的东西 http://mydomain/foo?id=99/goo 但是，出于某种原因，这是行不通的。有什么想法吗？谢谢，伊兰。

2热度

1回答

添加频道结果到队列完成的更习惯的方式

所以，现在，我只是传递一个指向Queue对象的指针（实现并不重要），并在goroutine的末尾调用queue.add(result)，它应该将事物添加到队列。我需要相同类型的功能 - 当然，使用逗号ok语法执行循环检查完成在性能方面与简单队列添加函数调用相比是不可接受的。有没有办法做到这一点更好，或不？