問題タブ [flatmap]

Learning Spark の本を読んでいるのですが、次のペアの rdd 変換を理解できませんでした。

それはrddに適用され{(1,2),(3,4),(3,6)}、変換の出力は{(1,2),(1,3),(1,4),(1,5),(3,4),(3,5)}

誰かがこれを説明してもらえますか。

typescript では、RxJS Observable.flatMap が Observable.fromPromise(promise) で作成された Observable で正しく動作していないようです。

変更検出をトリガーしないと思われます。

これらの2つの機能があります(_httpClientクラス内):

私がこれを行うとき：

ビューが更新されず、取得したデータを表示するには、どこか (ボタンなど) をクリックする必要があります。

しかし、 ObservableFromPremise( ) の代わりにBasicObservable()を使用すると、ビューが更新されます。

関数 get (UserConnector クラス内) の処理方法は次のとおりです。

そして私のページで：

そして、ここにテンプレートがあります:

どちらの場合も、取得したデータをコンソールに記録し、「アイテムの取得が完了しました」が、ObservableFromPremise() を使用すると、データは画面上で更新されません (ボタンをクリックするまで)。

私の設定：angular2（2.0.0-rc.1）、RxJS（5.0.0-beta.6）、zone.js（0.6.12）、e6-shim（0.35.00）

これについて何ができますか？私のコードのバグですか？zone.jsで？RxJSで？

助けてくれてありがとう

編集 1 : @Richard-Silveira で提案されているように、一時的な回避策として NgZone を使用します。

誰かが実際の解決策を共有してくれることを願っています =)

私は Scala を学んでおり、99 個の Scala の問題に取り組んでいます。次の演習の場合:

ネストされたリスト構造をフラット化します。例：

解は次のように与えられます。

しかし、なぜ次のことがうまくいかないのだろうと思っていましたか？

IntelJ IDEA は、「そのような署名では参照のフラット化を解決できません」と言って、問題がその部分flatten(ms)にあることを教えてくれます。Listflatten

2番目のコードが機能しない理由はありますか?

ツリー ノードのデスカンダントであるすべてのリーフ ノードを取得するように依頼されました。私はすぐに、この仕事を 1 行で行うことができるという考えにたどり着きました!

一見良かったのですが、すぐにStackOverflowExcepetionツリーの深さが 10 に達すると、受け入れられないものに遭遇しました。後で、再帰とストリームを使用しない実装を開発しました (ただし、私の脳はローストされflatMapています)が、ストリームの内部に触れずに再帰を実行することは不可能であることがわかったため、ストリームを使用して再帰を実行する方法があるかどうかはまだ疑問に思っています。それを行うには、新しい Op が必要になるか、すべての結果をすべてのステップRecursiveOpsに収集して、後で操作する必要があります。SetSet

見た目ほど良くない。ストリームはパイプラインであることを意図しています。その結果と中間結果は、端末操作が追加されるまで計算されません。上記のアプローチは、明らかにその原則に違反しています。ストリームほど簡単に並列化することもできません。すべての中間結果を手動で計算せずに再帰的に flatMap を実行できますか?

PS1: TreeNode 宣言:

これらのコードに混乱しています。なぜ違いが生じるのでしょうか?

更新: これらのコードを参照してください。

私はこのエラーに直面していますがflatMap、ではありませんmap。ブール演算はflatMap変換でサポートされていませんか?

次のコードがあるとします。

質問:

1) 関数 f(x) は、フラットマップ内の x ごとに 2 回呼び出されますか? 最初に f(x)._1 を呼び出し、次に f(x)._2 を呼び出したので。

2) フラップマップ (特にデータ読み取り部分) は並行して実行されますか? 3 つのノードがあり、各ノードには 32 個のコアがあるとします。--num-executors=2 と --executor-cores=32 を設定しました。別のノードは、ドライバー ノードとして使用されます。

上記の質問に答えるために、Spark/Scala のドキュメントをたくさん検索しましたが、そこからは何の回答も得られませんでした。自分のシステムでコードを実行しようとしました。そのように見えます

1) データ パーティションが 2 回処理されることがわかったため、f(x) が 2 回呼び出されます。しかし、よくわかりません。

2) Spark ログ ファイル システムの下に 2 つの executor フォルダーが作成され、各 executor からの stdout もいくつかあることに気付きました。しかし、私もよくわかりません。

ありがとう ！

flatMap を使用して Swift でビルドしようとしていますResource<T>が、奇妙なエラーが発生し続け、キャストを強制した場合にのみ機能します。

Resource<T>:

作業コード:

上記のコードは、キャストが常に成功するという警告を表示しますが、これは事実です。しかし、次のようにキャストを削除しようとすると:

次のエラーが発生します'flatMap' produces '[S.Generator.Element]', not the expected contextual result type 'T'?。

パーサーは次のstruct initようになります。

これまたは別のアプローチを修正する方法はありますか? ここでのアイデアは、多くのボイラープレート コードを記述する必要なく、任意の CKRecord を構造体に簡単に変換することです。