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

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

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

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

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

A. transactionDf.withColumn("storeId", convert("storeId", "string"))

B. transactionDf.withColumn("storeId", col("storeId", "string"))

C. transactionDf.withColumn("storeId", col("storeId").convert("string"))

D. transactionDf.withColumn("storeId", col("storeId").cast("string"))

E. transactionDf.withColumn("storeId", convert("storeId").as("string"))

A. 1.def count_to_target(대상):
2. 대상이 없음인 경우:
3. 반환
4.
5. 결과 = [범위(대상)]
6. 결과 반환
7.
8.count_to_target_udf = udf(count_to_target, ArrayType[정수형])
9.
10.transactionsDf.select(count_to_target_udf(col('predError')))

B. 1.def count_to_target(대상):
2. 대상이 없음인 경우:
3. 반환
4.
5. 결과 = 목록(범위(대상))
6. 결과 반환
7.
8.transactionsDf.select(count_to_target(col('predError')))

C. 1.def count_to_target(대상):
2. 대상이 없음인 경우:
3. 반환
4.
5. 결과 = 목록(범위(대상))
6. 결과 반환
7.
8.count_to_target_udf = udf(count_to_target, ArrayType(정수형()))
9.
10.transactionsDf.select(count_to_target_udf('predError'))
(옳은)

D. 1.def count_to_target(대상):
2. 결과 = 목록(범위(대상))
3. 결과 반환
4.
5.count_to_target_udf = udf(count_to_target, ArrayType(IntegerType()))
6.
7.df = transactionDf.select(count_to_target_udf('predError'))

E. 1.def count_to_target(대상):
2. 대상이 없음인 경우:
3. 반환
4.
5. 결과 = 목록(범위(대상))
6. 결과 반환
7.
8.count_to_target_udf = udf(count_to_target)
9.
10.transactionsDf.select(count_to_target_udf('predError'))

A. 1. 어디에
2. "제품 ID" > 2
3. 최대(2)

B. 1. 어디에
2. 거래Df[productId] >= 2
3. 제한(2)

C. 1. 필터
2. 제품 ID > 2
3. 최대(2)

D. 1. 필터
2. 열("제품 ID") >= 2
3. 제한(2)

E. 1. 여기서
2. 제품 ID >= 2
3. 제한(2)

A. transactionDf.withColumn("transactionDateFormatted", from_unixtime("transactionDate", format="dd/MM/yyyy"))

B. transactionDf.withColumnRenamed("transactionDate", "transactionDateFormatted", from_unixtime("transactionDateFormatted", format="MM/dd/yyyy"))

C. transactionDf.apply(from_unixtime(format="MM/dd/yyyy")).asColumn("transactionDateFormatted")

D. transactionDf.withColumn("transactionDateFormatted", from_unixtime("transactionDate", format="MM/dd/yyyy"))

E. transactionDf.withColumn("transactionDateFormatted", from_unixtime("transactionDate"))