Associate-Developer-Apache-Spark 試験問題 21
次のうち、Sparkアクションについて説明しているのはどれですか?
Associate-Developer-Apache-Spark 試験問題 22
次のコードブロックのどれがDataFrameitemsDfをエグゼキュータメモリに保存し、十分なメモリが利用できない場合は、それをシリアル化してディスクに保存しますか?
Associate-Developer-Apache-Spark 試験問題 23
次のコードブロックのうち、filePathにDataFrameとして保存されているJSONファイルを読み取るのはどれですか?
Associate-Developer-Apache-Spark 試験問題 24
以下に表示されるコードブロックにはエラーが含まれています。コードブロックは、DataFrametransactionsDfの数値およびnull許容列predErrorに適用されるPython関数add_2_if_geq_3の結果が列predErrorAddedに含まれるDataFrameを返す必要があります。エラーを見つけます。
コードブロック:
1.def add_2_if_geq_3(x):
2. xがNoneの場合:
3.xを返します
4. elif x> = 3:
5. x+2を返します
6.xを返します
7。
8.add_2_if_geq_3_udf = udf(add_2_if_geq_3)
9.9。
10.transactionsDf.withColumnRenamed( "predErrorAdded"、add_2_if_geq_3_udf(col( "predError")))
コードブロック:
1.def add_2_if_geq_3(x):
2. xがNoneの場合:
3.xを返します
4. elif x> = 3:
5. x+2を返します
6.xを返します
7。
8.add_2_if_geq_3_udf = udf(add_2_if_geq_3)
9.9。
10.transactionsDf.withColumnRenamed( "predErrorAdded"、add_2_if_geq_3_udf(col( "predError")))
Associate-Developer-Apache-Spark 試験問題 25
SparkのDataFrameに関する次の説明のうち正しくないものはどれですか?