scala

1熱

1答えて

私はhost-level API with a queueを使用しています。 private val (queueSource, connectionPool) = Source.queue[(HttpRequest, Promise[HttpResponse])](queueSize, OverflowStrategy.backpressure).async .viaMat(poolF

1熱

1答えて

文字列からケースオブジェクトを作成するためのscala "factory"デザインパターン

私はスカラーが新しく、外部ソースによって文字列列挙型から取り出された正しい大文字小文字クラス（特性に適合する）を作成するためのスカラーを探しています。ソースが外部であるため、入力が正しいという妥当な検証が必要であり、有効な入力があれば正しいケースクラスが返されます。私は、これは与えられた形質のオプションのケースクラスを返す「工場」であることを前提となり例： trait ProcessingMec

1熱

1答えて

SBTキーは自動的に1

をSBTするために、移行後に大文字ます私は0.13から1.0.4へのsbtプラグインを移行していますプラグインは、次のようにInputKeyを定義しています lazy val myKey = InputKey[Unit]("foo-bar", "") このキーを使用するには、私は（SBTコンソールから）実行します： foo-bar が、1.0.4をSBTにアップグレードした後、私はエラー

0熱

1答えて

カスタムスティックプロファイルの実行例外の取得

スムースで自分のカスタムプロファイルを使用しようとすると、Imが例外になります。なぜ私はそれを使用したいの理由は、JSONを私のpostgresqlデータベースに保存したいからです。したがって、私はpg-slickを使用しています。例外： slick.jdbc.PostgresProfile $はutil.ExtendedPostgresProfileにキャストできません。これはExtende

-1熱

1答えて

大きなデータフレームをスパークで効果的にキャッシュする

現在11,000ファイルを処理中です。各ファイルは、前のものとの連合となるデータフレームを生成します。以下はコードです var df1 = sc.parallelize(Array(("temp",100))).toDF("key","value").withColumn("Filename", lit("Temp")) files.foreach(filename => { v

-1熱

1答えて

Slick結果が見つかりませんでした

私はSlickには新しく、いくつかの問題を抱えて私を苦しめています。私のデータベースに私は自分のメールアドレスを持つユーザーを保存しました。ただし、このメソッドを実行すると（DAOで実装されています）： def getByEmail(email: String): Future[Option[User]] = { println(s":${email}:") println

0熱

1答えて

ユニットが見つかりましたが </p> <p>ダブル

def Perm_Function(xs: List[(Int,Int)], Dimensions: Int): Double = { var sum=0.0 for(i <- 1 to Dimensions) { sum=sum+(Perm_help(xs,i)) } } 必要な私は、コードの上に書きましたが、それはエラーを与えている：が見つかりまし

1熱

1答えて

ブロードキャストハッシュ結合（スパークデータフレームあり）

スパーク1.6.0でブロードキャストハッシュ結合を実行しようとしましたが、成功できませんでした。は私がDFに説明ブロードキャスト・ヒントを使用していたとしても val DF1 = sqlContext.read.parquet("path1") val DF2 = sqlContext.read.parquet("path2") val Join = DF1.as("tc").join(

0熱

1答えて

非空のイテレータが印刷後に空になった

スカラでは、空ではないイテレータを返したgetLinesを使用してファイルを読み取りました。それから、私はforループを使って行を表示しました。その後、再度印刷しようとすると、空のIteratorと表示されます。誰か説明できますか？あなたは Iterator状態変化を横断保つようので、非常に Iteratorの振る舞いを期待されている scala> c res1: Iterator[String

0熱

1答えて

、別の列の値がI放送変数として配列を有し、それは整数を含む放送可変配列

にある場合、新しい列に値を追加： broadcast_array.value Array(72159153, 72159163, 72159202, 72159203, 72159238, 72159398, 72159447, 72159448, 72159455, 72159492... Iがデータセット内の列を有しています（コールはbroadcast_arrayにあるかもしれないInt