scala

-2熱度

1回答

我有一個類，它有一個打印出字符串的方法。我想重寫toString函數，以便將字符串打印爲t | h | i | s。我怎麼做？

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 但是，出於某種原因，這是行不通的。有什麼想法嗎？謝謝，伊蘭。