問題タブ [take]

クエリ処理エンジンとして Apache Spark を使用しています。最近直面した問題は、rdd の要素数を制限したいということです。

rdd には、rdd から指定された数の要素のみを取得するために使用できる take 関数があることを知っています。ただし、この関数を適用すると、結果は rdd になりません。

この機能を適用しても、rdd は (変換として) そのままにしておく必要があります。

だから今のところ私がしたことは次のとおりです

これはかなりの時間の無駄だと思います。ただし、マップ、フィルターなどの変換を使用してこの機能を実装する方法は考えられません。

私がここでやったことなしにこれを達成する方法はありますか?

ありがとう

私は Haskell を学んでいます。次のような関数があります。

私がこれをやりたいのは、無限のリストでn個の要素を返すことだけですが、なぜこれが機能しないのかわかりません。バインディングを放棄せずに修正する方法の説明 (?)

そこで、リスト (xs) を受け取り、それを出力として 3 つの部分に分割するこの関数定義に出くわしました。

問題は、私がそれを理解するのに苦労しているということです。リスト (xs) の n を取る最初の部分を理解しています。ここで、n はリスト (xs) の長さを 3 で割ったものとして定義されています。

誰かがこの機能について説明してくれたら、それは素晴らしいことです。

コードは次のとおりです。