Associate-Developer-Apache-Spark 試験問題 36
Spark 実行階層におけるタスクの役割を説明しているものは次のうちどれですか?
Associate-Developer-Apache-Spark 試験問題 37
Spark が Hadoop と比較して持つパフォーマンス上の大きな利点の 1 つは次のうちどれですか?
Associate-Developer-Apache-Spark 試験問題 38
以下に表示されているコード ブロックにはエラーが含まれています。コード ブロックは、結合の実行時に最大 20 MB のサイズの DataFrame がすべてのワーカー ノードにブロードキャストされるように Spark を構成する必要があります。
エラーを見つけてください。
コードブロック:
エラーを見つけてください。
コードブロック:
Associate-Developer-Apache-Spark 試験問題 39
以下に示すコード ブロックは、列transactionDateFormをDataFrametransactionsDfに追加する必要があります。この列は、transactionDate 列の Unix 形式のタイムスタンプを 4 月 26 日 (日曜日) のように文字列型で表現する必要があります。これを達成するには、コード ブロック内の空白を正しく埋める答えを選択してください。
トランザクションDf.__1__(__2__, from_unixtime(__3__, __4__))
トランザクションDf.__1__(__2__, from_unixtime(__3__, __4__))
Associate-Developer-Apache-Spark 試験問題 40
以下に表示されているコード ブロックにはエラーが含まれています。コード ブロックは、一意の storeId によってグループ化された列値の行の平均を返す必要があります。エラーを見つけてください。
コードブロック:
transactionsDf.agg("ストアID").avg("値")
コードブロック:
transactionsDf.agg("ストアID").avg("値")
