scala-generics

    1

    1答えて

    でジェネリックを使用している間: import scala.collection.mutable class test { val car = mutable.Map.emprty[String, (Int,Int)] read[String, (Int,Int)] ("file.txt",car) def read[T,V] (fileName:String,

    3

    1答えて

    このメソッドをコンパイルするにはどうしたらいいですか?不思議なことに、暗黙のスパークはすでにインポートされています。 def loadDsFromHive[T <: Product](tableName: String, spark: SparkSession): Dataset[T] = { import spark.implicits._ spark.sql(s"SELEC

    0

    1答えて

    それは少し面倒に感じていると私はファンではないしかし、私はJson4sにおけるjオブジェクトのうちフィールド val x = (obj \ "Type").asInstanceOf[JString].values を取得するためのAPIのようなxp​​athがあります知っていますapisのような象徴的なもの。私は種類のこのような何かしたい: implicit class JsonExtensi

    1

    1答えて

    私は、反復処理可能に関数を適用し、述語が真である最初にマッピングされた結果を返し組み合わせた地図と-見つける機能書いた: implicit class EnhancedIterable[A, B[X] <: Iterable[X]](it: B[A]) { def mapAndFind[B](f: A => B, p: B => Boolean): Option[B] = {

    1

    1答えて

    Akkaストリームで次の関数のラッパーを作成しようとしています。 RestartFlow.withBackoff(minBackoff = 3.seconds, maxBackoff = 30.seconds, randomFactor = 0.2) { () => s } ここで、sはバックオフで折り返しているソースです。この RetryFlow(

    0

    1答えて

    要素の種類に制限を持つタイプセーフな異種リストを定義しようとしています(たとえば、タイプAの後にタイプAが出現できないなど)。私の構造を無形のHListに変換しようとすると、問題が発生します。私は次のエラーを取得する sealed trait Hierarchy { type HListType <: HList def toHList : HListType de

    1

    1答えて

    は、私は私のプロジェクトで使用していますいくつかのカフカチャンネルの階層構造を持っている: 私の基本特性は次のとおりです。 trait SendChannel[A, B] extends CommunicationChannel { def send(data:A): B } 今、私は、共通のカフカを持っているが trait CommonKafkaSendChannel[A, B,