DataStream API
DataStream API
Flink의 DataStream 프로그램은 데이터 스트림에 대한 변환(예: 필터링, 상태 갱신, 윈도우 정의, 집계)을 구현하는 일반 프로그램입니다. 데이터 스트림은 처음에 다양한 소스(예: 메시지 큐, 소켓 스트림, 파일)에서 생성됩니다. 결과는 sink를 통해 반환되며, 예를 들어 파일에 데이터를 쓰거나 표준 출력(예: 커맨드라인 터미널)으로 출력할 수 있습니다.
Python DataStream API는 DataStream API의 Python 버전으로, Python 사용자가 Python DataStream API 작업을 작성할 수 있게 해줍니다.
출처: 문서