A. transactionDf.format("parquet").option("mode", "append").save(경로)

B. 코드 블록에 DataFrameWriter에 대한 참조가 없습니다.

C. save()는 느리게 평가되며 조치가 뒤따를 필요가 있습니다.

D. 명령이 기본 모드를 사용하도록 모드 옵션을 생략해야 합니다.

E. 코드 블록에 파티션을 처리하는 bucketBy 명령이 없습니다.

F. DataFrame을 parquet 파일로 저장해야 하는 경우 경로가 잘못된 방법으로 전달되고 있습니다.

A. 1. 필터
2. col("공급자").isin("스포츠")
3. "항목 이름"
4. 폭발(col("속성"))

B. 1. 어디에
2. col("공급자").contains("스포츠")
3. "항목 이름"
4. "속성"

C. 1. 어디에
2. col(supplier).contains("스포츠")
3. 폭발(속성)
4. 항목 이름

D. 1. 여기서
2. "스포츠".isin(col("공급업체"))
3. "항목 이름"
4. array_explode("속성")

E. 1. 필터
2. col("공급자").contains("스포츠")
3. "항목 이름"
4. 폭발("속성")

A. DataFrame.repartition(12)

B. DataFrame.coalesce(6).shuffle()

C. DataFrame.coalesce(6)

D. DataFrame.coalesce(6, 셔플=True)

E. DataFrame.repartition(6)

A. 여러 문자열 열을 단일 열로 연결하면 메모리 부족 오류를 방지할 수 있습니다.

B. 파티션 크기를 줄이면 메모리 부족 오류에 도움이 될 수 있습니다.

C. 조인에서 자동으로 브로드캐스트되는 데이터의 양을 제한하면 메모리 부족 오류에 도움이 될 수 있습니다.

D. 드라이버에 반환되는 직렬화된 데이터의 최대 크기에 대한 제한을 설정하면 메모리 부족 오류를 방지하는 데 도움이 될 수 있습니다.

E. 각 실행기에서 사용할 수 있는 코어 수를 줄이면 메모리 부족 오류를 방지하는 데 도움이 됩니다.

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

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

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

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

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