Apache Flink — 스트림을 엔진으로 돌린다
파드 안에 Flink 2.3 클러스터를 띄워 Flink SQL 로 잡을 돌립니다. 동적 테이블과 변경 로그, 이벤트 시간과 워터마크, 창 함수, 스트림 조인, 중복 제거와 Top-N, 상태와 TTL, 체크포인트와 세이브포인트, 실행 계획, 패턴 인식을 다룹니다. 채점은 엔진이 남긴 출력과 원본에서 직접 계산한 기대값을 대조합니다. 데이터 파이프라인 코스의 워터마크 모듈을 먼저 보면 더 잘 읽힙니다.
고급 · 레슨 30 · 실습 10
커리큘럼
클러스터 한 벌
동적 테이블과 변경 로그
이벤트 시간과 워터마크
창 TVF 와 창 Top-N
- 창 TVF — 행에 창 열 세 개를 붙이는 함수 reading
- 창 TVF 네 가지로 같은 주문을 자른다 lab
- 퀴즈: 창 TVF 와 창 Top-N quiz
스트림 조인
- 스트림 조인 — 무엇을 얼마나 오래 기억하는가 reading
- 세 가지 조인으로 주문을 붙인다 lab
- 퀴즈: 스트림 조인 세 가지 quiz
중복 제거와 Top-N
상태와 TTL
- 상태는 어디에 얼마나 남는가 — 연산자·TTL·백엔드 reading
- 실행 계획에서 상태와 TTL 을 읽는다 lab
- 퀴즈: 상태와 TTL quiz