A. 직업

B. 작업

C. 집행자

D. 슬롯

E. 스테이지

A. 1. pyspark.sql에서 T로 유형 가져오기
2.evaluateTestSuccessUDF = udf(evaluateTestSuccess, T.BooleanType())
3.transactionsDf.withColumn("결과", 평가TestSuccessUDF(col("storeId")))

B. 1.evaluateTestSuccessUDF = udf(evaluateTestSuccess)
2.transactionsDf.withColumn("결과", 평가TestSuccessUDF(storeId))

C. 1.pyspark.sql에서 T로 유형 가져오기
2.evaluateTestSuccessUDF = udf(evaluateTestSuccess, T.IntegerType())
3.transactionsDf.withColumn("결과", 평가TestSuccess(col("storeId")))

D. 1.evaluateTestSuccessUDF = udf(evaluateTestSuccess)
2.transactionsDf.withColumn("결과", 평가TestSuccessUDF(col("storeId")))

E. 1. pyspark.sql에서 T로 유형 가져오기
2.evaluateTestSuccessUDF = udf(evaluateTestSuccess, T.BooleanType())
3.transactionsDf.withColumn("결과", 평가TestSuccess(col("storeId")))

A. 슬롯은 실행기의 다른 이름입니다.

B. 작업보다 실행자가 적어야 합니다.

C. 실행기는 단일 코어에서 실행됩니다.

D. 작업보다 슬롯이 더 많아야 합니다.

E. 작업이 슬롯을 통해 병렬로 실행됩니다.

A. 실행자는 드라이버에 의해 시작됩니다.

B. 기본적으로 응용 프로그램이 완료되면 실행기가 중지됩니다.

C. 각 노드는 단일 실행기를 호스트합니다.

D. Executor는 메모리에만 데이터를 저장합니다.

E. 실행기는 여러 응용 프로그램을 제공할 수 있습니다.

A. transactionDf.write.save("/FileStore/transactions.csv")

B. transactionDf.write.format("csv").mode("error").path("/FileStore/transactions.csv")

C. transactionDf.write.format("csv").mode("ignore").path("/FileStore/transactions.csv")

D. transactionDf.write("csv").mode("error").save("/FileStore/transactions.csv")

E. transactionDf.write.format("csv").mode("error").save("/FileStore/transactions.csv")