DataStream API
DataStream API (V2)
DataStream API V2는 기존 DataStream API를 점진적으로 대체하기 위한 새로운 API 집합이에요. 현재 실험 단계(experimental stage)에 있으며 생산(production) 환경에서 완전히 사용 가능한 상태는 아니에요.
출처: 문서
본문
DataStream API V2는 상태를 가진 스트림 처리(stateful stream processing) 애플리케이션을 더 명확하고 구조화된 방식으로 개발할 수 있게 설계됐어요. 이 섹션에서는 다음 주제를 다뤄요:
- Building Blocks: DataStream API의 가장 기본적인 요소(데이터 스트림, 파티셔닝, 프로세스 함수, 상태, 타이머, 워터마크).
- Context and State Processing: 상태를 가진 애플리케이션을 개발하는 방법.
- Time Processing: 프로세싱 타임과 이벤트 타임 처리 방법.
- Watermark: 사용자 정의 이벤트(워터마크)를 정의하고 처리하는 방법.
- Builtin Functions: 윈도우 집계와 조인을 위한 내장 기능.
각 하위 문서는 구체적인 API 개념과 사용 방법을 설명해요.