問題タブ [flatmap]
For questions regarding programming in ECMAScript (JavaScript/JS) and its various dialects/implementations (excluding ActionScript). Note JavaScript is NOT the same as Java! Please include all relevant tags on your question; e.g., [node.js], [jquery], [json], [reactjs], [angular], [ember.js], [vue.js], [typescript], [svelte], etc.
scala - flatten と flatMap(identity) に違いはありますか?
これら2つの機能に違いはありますか？どちらか一方を使用するのが適切なのはいつですか? トレードオフはありますか？
scala - Spark: RDD の Seq を RDD に変換する方法
Spark & Scala を始めたばかりです
複数のファイルを含むディレクトリがあり、それらを使用して正常にロードしました
今はもう一つ上のレベルに行きたいと思っています。実際には、ファイルを含むサブディレクトリを含むディレクトリがあります。私の目標は、ファイルの名前と内容を表すを取得しRDD[(String,String)]て、先に進むことです。RDD
私は次のことを試しました：
しかし、私はこれをに変換するにはどうSeq[RDD[(String,String)]]
すればよいですか?SeqRDD[(String,String)]
それとも、私は正しいことをしていないので、別のアプローチを試す必要がありますか?
編集：コードを追加
scala - scala 語長ヒストグラムの表示 scala
一連の行を入力として取り込み、語長の分布を追跡しています。入力の改行を含む余分な空白は問題ではありません。入力の終わりに達した後、出力は単語の長さの分布のテキストベースのヒストグラムです: 例: "Hey How are you hey am good"
出力：1 - 0、2 - 1、3 - 5、4 - 1、5 - 0
ここで (最初の文字は単語の長さで、2 番目の文字はその長さの単語の数です)。私は書いた
同じ長さの単語をグループ化し、イテレータまたはマップに格納したい
望ましい結果が得られません。助言がありますか？
scala - scalaでマップ関数をフィルタリングする場合の使用方法は?
から生成された hadoopFiles オブジェクトを取得しましたsc.newAPIHadoopFile。
操作とフィルターを使用して hadoopFiles のすべての行を反復処理するつもりです。この場合、ifチェックが適用され、例外がスローされます。
ただし、if(pair.length == 2)パーツを削除すると、正常に動作します。
だれかこの現象の理由を教えてくれませんか。また、その説明を正しく適用する方法を教えてifください。どうもありがとう！
PSこの単純化された例を使用してテストできます。
scala - flatMap へのこの呼び出しに暗黙的なものはありますか?
このコードでは：
から取得: scala のサブディレクトリ内のすべてのファイルを一覧表示するにはどうすればよいですか?
なぜflatMap(recursiveListFiles)コンパイルするのですか？パラメータをrecursiveListFiles受け入れるように？Fileファイル パラメータは暗黙的に に渡されrecursiveListFilesますか?
java - Java8 flatmap がリストのリストを返すのはなぜですか?
次のJava 8コードを使用してList、関数Listのオブジェクトへの「適用」を実装しようとしていました。File
私が得る出力は次のとおりです。
集めたすべてのファイルに関数のリストを適用しています...
質問 1: 最初の出力では 1 つのリストしか得られないのに、2 番目の出力ではリストのリストが得られるのはなぜですか? どちらもコレクションのストリームに対して flatmap を使用します。
質問 2: Java 8 で同じことを達成するためのより良い方法はありますか?