A. 2.4

B. 24 0

C. .24

D. .48

E. 4.8

A. 아니요: 삭제된 레코드가 포함된 파일은 BACUM 명령을 사용하여 무효화된 데이터 파일을 제거하기 전까지는 타임 트래블을 통해 계속 접근할 수 있습니다.

B. 예: Delta Lake ACID 보증은 DELETE 명령이 해당 레코드를 완전히 영구적으로 삭제하는 데 성공했음을 보장합니다.

C. 아니요: 변경 데이터 피드는 삽입 및 업데이트만 추적하고 삭제된 레코드는 추적하지 않습니다.

D. 아니요: Delta Lake의 DELETE 명령은 MERGE INTO 명령과 함께 사용할 때만 ACID 보장을 제공합니다.

A. customer_churn_params 테이블의 모든 행에 이탈 예측 모델을 적용하되, 예측값이 변경되지 않은 행은 무시하고 예측 테이블에 업서트하는 로직을 구현하십시오.

B. 데이터가 기록될 때 current_timestamp()를 호출하여 채워지는 필드를 포함하도록 덮어쓰기 로직을 ​​수정합니다. 이 필드를 사용하여 특정 날짜에 기록된 레코드를 식별합니다.

C. 현재의 덮어쓰기 로직을 ​​변경된 레코드만 수정하는 MERGE 문으로 대체하고, 변경 데이터 피드에서 식별된 변경된 레코드에 대한 예측 로직을 작성합니다.

D. 배치 작업을 전체 출력 모드를 사용하는 구조화된 스트리밍 작업으로 변환합니다. 구조화된 스트리밍 작업이 customer_churn_params 테이블에서 데이터를 읽어 이탈 모델을 기반으로 점진적으로 예측하도록 구성합니다.

A. 총 디스크 공간은 일정하게 유지됩니다.

B. 5분 평균 부하량이 일정하게 유지됩니다/평탄하게 유지됩니다

C. 수신 바이트 수는 초당 8천만 바이트를 초과하지 않습니다.

D. CPU 사용률은 약 75%입니다.

E. 네트워크 I/O는 절대 급증하지 않습니다.

A. 자동 로더를 사용하여 계정 기록 디렉터리의 새 파일을 구독하고, 구조화된 스트리밍 트리거를 한 번 실행하여 새로 감지된 파일을 계정 현재 테이블에 일괄 업데이트하도록 구성합니다.

B. 사용자 ID별로 그룹화하고 마지막 업데이트 값이 최댓값인 계정을 기준으로 필터링하여 계정 내역 테이블에 대한 쿼리 결과를 사용하여 각 배치마다 계정 현재 테이블을 덮어씁니다.

C. 계정 내역에서 마지막 업데이트 필드와 최근 처리 시간, 그리고 사용자 ID별 최대 마지막 로그인 시간을 기준으로 레코드를 필터링하고, 각 사용자 ID에 대해 가장 최근 값을 업데이트하거나 삽입하는 병합 문을 작성합니다.

D. Delta Lake 버전 기록을 사용하여 계정 기록의 최신 버전과 이전 버전 간의 차이점을 가져온 다음 이러한 기록을 계정 현재 상태에 기록합니다.

E. 계정 내역에서 마지막 업데이트 필드와 최근 처리 시간을 기준으로 레코드를 필터링하고, 사용자 이름이 중복되지 않도록 합니다. 각 사용자 이름에 대해 최신 값을 업데이트하거나 삽입하는 병합 문을 작성하세요.