scala

1熱

1答えて

jsonを返すレストサービスにGET HTTPコールを行います。私はjsonをscalaオブジェクトに構文解析したいと思いますが、ここで私は固まってしまいました。 name := "ScalaHttp" version := "1.0" scalaVersion := "2.11.8" libraryDependencies ++={ val akkaV = "2.4.5"

1熱

2答えて

Oozieを使用してHbaseにスパークする

SparkからHbaseにテーブルを作成してデータを挿入しようとしましたが、そこからデータを読み込みました。コマンドラインからsparkジョブを実行するとうまく動作します。しかし、それはoozieを使用して実行しようとするたびに、異なるタイプの例外をスローしています。ここでここに私のスパークHBaseのコード val sc = new SparkContext("local", "Hbase

0熱

2答えて

Spark StreamingのreduceByKeyAndWindowを複数の値で使用

は、Spark StreamingのreduceByKeyAndWindow関数に関する質問があります。これは素朴かもしれませんが、ScalaとSparkの両方にとって新しいものです。を実行する方法はありカウント（ロング）：列1：キー、コラム2：金額（ロング）、 3列は私のデータを解析した後、私は3つの列と、このデータセットを持っていますreduceByKeyAndWindow関数を使用し

0熱

1答えて

クォート（Java）で起動されたトリガーを保存する方法はありますか？

私たちのアプリでは主スケジューラーとして石英を使用しています。正常に実行されたトリガーとジョブは、正常に実行された方法で削除されます。ただし、デバッグと追跡の目的で、その情報を保持する必要があります。 storeDurablyをtrueに設定することで、ジョブに対して簡単に実行できます。同じトリガーを達成する方法はありますか？ありがとうございました。

0熱

1答えて

Scalaストリームは中間オブジェクトをメモリに保持します

私はScalaでストリームを書き込もうとしていますが、なぜメモリ内にいくつかの中間オブジェクトを保持する理由がありません。ここでは、私のコードの簡易版である： val slols = { def genLols (curr:Vector[Int]) :Stream[Int] = 0 #:: genLols(curr map (_ + 1)) genLols(List.fill

1熱

1答えて

複数のパラメータリストと部分的な結合をスカラ

私はScala Courseraコースをやっていますが、講義では複数のパラメータリストが実際にどのように機能しているか説明していないようです。以下のaverageDamp（）関数のような主張は、最初の引数（f）だけで呼び出すことができ、2番目の後に呼び出すことができます。ただし、 "_"を呼び出して明示的に部分的なバインディングを行う必要があります。ただし部分的にバインドされた関数と一致するシ

1熱

2答えて

Scala：リストを[人]にしてマップに変換する[文字列、リスト[人]]

私はScalaには新しく、Collectionsの使い方を理解しようとしています。 List [People]が名前を持っている場合、これをMap [Person.getName、List [People]]にする方法があります。私は list map (t => t.getName() -> t) toMap, を試みたが、唯一の地図[名、人々]を返します。これはどうすればいいですか？あ

0熱

1答えて

スカラスイングアプリケーション内からクラスにアクセスする方法

私はスイングアプリケーションを作成し、その内部にクラスアライメントのオブジェクトを作成したいと考えています。しかし、私がこれをしようとしているとき、私はこのエラーメッセージを受け取りました： "シンボルアラインメントを解決できません"。誰かが私が間違っていることを私に説明することはできますか？ package scala.swing package test import event._

2熱

1答えて

GroovyからScala動的関数を呼び出せますか？

私はScalaでGradleプラグインを作成しています。 Gradle DSLを介してプラグインと関連タスクを設定できるようにするには、メソッドを動的に呼び出すことができる必要があります（実際には存在しないメソッド）。私がGroovyでプラグインを書いていたのであれば、hereのようにmethodMissingまたはpropertyMissingを使用します。 Scalaでは、dynamic me

2熱

1答えて

Scalaでの並列処理パターン

これは愚かな質問ではないか、私は何か明白でないことを願っています。私が行くのユニットテストを書いた object parallelism { val forkJoinPool = new ForkJoinPool abstract class TaskScheduler { def schedule[T](body: => T): ForkJoinTask[T]