• [解決済み] sbtのlibraryDependenciesで言うところの++=と+=の違いは何ですか?

    質問 Scalaとsbtは初めてで、何が違うのか理解できません。 libraryDependencies ++= Seq(...) そして libraryDependencies += ... 解決方法は? それは += dep または ++= Seq(dep, dep2, dep3) : "もちろん、++= を使って依存関係のリストを一度に追加することもできま

    2022-02-18 04:29:15
  • [解決済み] NoClassDefFoundError: org/apache/hadoop/fs/StreamCapabilities (s3データをsparkで読み込む際に発生します。

    質問 ローカルの開発マシンで(Intellijを通して)Amazon s3からデータを読み込む簡単なsparkジョブを実行したいのですが、どうすればいいですか? 私の build.sbt ファイルを作成します。 scalaVersion := "2.11.12" libraryDependencies ++= Seq( "org.apache.spark" %% "spa

    2022-02-18 03:28:44
  • [解決済み] Spark Implicit $ for DataFrame(データフレーム用暗黙の$)。

    質問 のどこにあるのでしょうか? sqlContext.implicits._ は、親データフレームの列に対するデータフレームの呼び出しを表す$"string"を定義しているのでしょうか?具体的には、以下のようなものを見て混乱しました。 import sqlContext.implicits._ df.where($"type".isin("type1","type2") and $"s

    2022-02-17 19:58:15
  • [解決済み] Scalaで「:+」は何を意味するのか

    質問 というScalaのコードを見かけました。 def next(): Array[String] = someVariable.next() :+ iterator.key ここで someVariable にはメソッドがあります。 next() で次の行を取得し、そのイテレータは Iterator[String] . とは何ですか? :+ の意味は? どのよう

    2022-02-17 12:43:27
  • [解決済み] Scalaの「コンテキストバウンド」とは何ですか?

    質問 Scala 2.8の新機能の1つにコンテキスト・バウンズがあります。コンテキストバウンドとは何か、どこで役に立つのか? もちろん、まず検索してみました(そして、例えば これ しかし、本当に明確で詳細な情報は見つかりませんでした。 どのように解決するのですか? は見つかりましたか? この記事 ? 配列の改良の中で、新しいコンテキストバウンド機能を取り上げています。

    2022-02-16 12:01:28
  • [解決済み] Scala マップ foreach

    質問 が与えられた。 val m = Map[String, Int]("a" -> 1, "b" -> 2, "c" -> 3) m.foreach((key: String, value: Int) => println(">>> key=" + key + ", value=" + value)) なぜコンパイラは文句を言うのか e

    2022-02-16 02:51:10
  • [解決済み] scala 2.11.0 REPL を終了するには?

    質問 scalaの最後のバージョン(2.10.3)のREPLでは、次のように入力することができます。 exit でREPLを終了します。 しかし、Scala 2.11.0では、これは機能しません。 $ scala Welcome to Scala version 2.11.0 (Java HotSpot(TM) 64-Bit Server VM, Java 1.7.0_51). Typ

    2022-02-15 01:06:48
  • [解決済み] Scala 無名クラスでextendsを使用する方法

    質問 ScalaでAnonymousクラスから別のクラスを拡張する方法はありますか?つまり、以下のようなものです。 abstract class Salutation { def saybye(): String = "Bye" } class anotherClass() { def dummyFunction() = { val hello = new {

    2022-02-14 22:10:14
  • [解決済み] Scalaで定期的に関数を実行する

    質問 任意の関数を毎回呼び出したい n 秒間です。基本的に私は次のものと同じものが欲しいのです SetInterval をJavascriptから取得しました。Scalaでこれを実現するにはどうしたらいいですか? どのように解決するのですか? の標準的なものを使用することができます。 java.util.concurrent : import java.util.concu

    2022-02-14 14:04:51
  • [解決済み】Spark - アプリの投稿時に「設定にマスターURLが設定されている必要があります」というエラーが発生する

    質問事項 ローカルモードでは問題なく動作するSparkアプリがあるのですが、Sparkクラスタにサブミットすると問題が発生します。 エラーメッセージは以下の通りです。 16/06/24 15:42:06 WARN scheduler.TaskSetManager: Lost task 2.0 in stage 0.0 (TID 2, cluster-node-02): java.lan

    2022-02-13 05:51:39
  • [解決済み] Scalaでswitch/case(単純なパターンマッチ)を使うには?

    質問内容 とても些細なことで行き詰っている自分に気づきました :-] 。 enumを手に入れました。 object Eny extends Enumeration { type Eny = Value val FOO, BAR, WOOZLE, DOOZLE = Value } あるコードでは、これを条件付きで数値に変換する必要がある(変数と数値

    2022-02-13 03:15:07
  • [解決済み] Scalaで定数メンバを定義するには?

    質問 Scalaのプログラムで円周率や黄金比などの定数を定義する場合、どのような方法が正しいですか? 例として、C#ではこんなことができるんです。 class Example { public readonly static Double GoldenRatio; static Example () { GoldenRatio = (1.0 +

    2022-02-12 07:51:33
  • [解決済み] NotUsedとDoneの理解

    質問 の目的・意義が理解できず困っています。 NotUsed と Done をAkka Streamsに追加しました。 次の2つの簡単な例を見てみましょう。 NotUsedを使用する。 implicit val system = ActorSystem("akka-streams") implicit val materializer = ActorMaterialize

    2022-02-12 03:22:07
  • [解決済み] Scala - case classを木のように(きれいに)印刷する方法

    質問内容 ScalaのCombinatorを使ってパーサーを作っています。すごいですね。私が最終的に行き着いたのは、絡み合ったケースクラスの長いリストです。 ClassDecl(Complex,List(VarDecl(Real,float), VarDecl(Imag,float))) ただ、100倍長いだけです。このようなケースクラスをツリー状に印刷して見やすくする良い方法はないものでし

    2022-02-12 03:06:19
  • [解決済み] Seq[Future[Person]]ではなく、Future[Seq[Person]]を取得する方法

    質問 以下の2つの外部呼び出しがあります。 Future[Seq[People]]を与えるもの。 person_id を受け取り、person_status を Future[String] として返す。 最初の呼び出しで利用可能なシーケンスから、2番目の呼び出しを使用して各人の状態を更新する必要があります。これは私が試した方法です。 getFuturePeople.map

    2022-02-11 12:42:35
  • [解決済み] SparkはYarnクラスタ上で動作しています exitCode=13:

    質問 私はspark/yarnの初心者ですが、yarnクラスタ上でsparkのジョブを投入するとexitCode=13に遭遇します。sparkのジョブがローカルモードで実行されているときは、すべてがうまくいっています。 使用したコマンドは /usr/hdp/current/spark-client/bin/spark-submit --class com.test.sparkTest

    2022-02-10 03:03:33
  • [解決済み] 実行時に変数の型を取得したい

    質問 実行時に変数の型を取得したいのですが、どうすればよいですか? どうすればよいですか? どのように解決するのですか? つまり、厳密に言えば、"変数の型"は常に存在し、型パラメータとして渡すことができるのです。例えば val x = 5 def f[T](v: T) = v f(x) // T is Int, the type of x しかし 何をしたいのか する

    2022-02-10 02:19:27
  • [解決済み] Scala: スライド(N,N) vs グループ化(N)

    質問 最近、コレクションを再処理することなくn個の要素で反復処理する必要があるときに、sliding(n,n)を使っていることに気づきました。私は、grouped(n)を使用してこれらのコレクションを反復する方がより正しいかどうか疑問に思っていました。私の質問は、パフォーマンスの観点から、この特定のケースでどちらかを使用する特別な理由があるかどうかです。 val listToGroup =

    2022-02-10 01:51:52
  • [解決済み] GSON JsonObject "Unsupported Operation Exception: null" getAsString

    質問 ScalaでPlay!アプリを動かしています。レスポンスがJSON文字列であることが予想されるリクエストをしています。デバッガで確認すると、JsonElementは期待通りのすべての情報を持ってOKを返します。しかし、問題は、そのJsonElementに対して実際にメソッドを実行しようとしたときです。 val json = WS.url("http://maps.googleapis

    2022-02-09 13:46:17
  • [解決済み】scalacコンパイルで "object apache is not a member of package org "と表示される。

    質問 私のコードは import org.apache.spark.SparkContext インタラクティブ・モードでは実行できるのだが、scalac を使ってコンパイルすると、次のようなエラーメッセージが表示された。 オブジェクトapacheはパッケージorgのメンバーではありません。 これはパスの問題のようですが、パスの設定方法がよくわかりません。 どのように解

    2022-02-09 05:49:34