아파치 플링크로 하는 스트림 데이터 처리

1장. 상태가 있는 스트림 처리 소개
__전통적인 데이터 인프라
____트랜잭션 처리
____분석 처리
__상태가 있는 스트림 처리
____이벤트 주도 애플리케이션
____데이터 파이프라인
____스트리밍 분석
__오픈소스 스트리밍 처리의 진화
____스트림 처리의 역사
__플링크 빠르게 살펴보기
____첫 번째 플링크 애플리케이션 실행
__요약


2장. 스트리밍 처리 기초
__데이터플로우 프로그래밍 소개
____데이터플로우 그래프
____데이터 병렬화와 태스크 병렬화
____데이터 교환 전략
__병렬 스트림 처리
____지연과 처리율
____데이터 스트림 연산
__시간 시멘틱
____스트리밍 처리에서 1분
____처리 시간
____이벤트 시간
____워터마크
____처리 시간과 이벤트 시간
__상태와 일관성 모델
____태스크 실패
____결과 보장
__요약


3장. 아파치 플링크 아키텍처
__시스템 아키텍처
____플링크 컴포넌트
____애플리케이션 배치
____태스크 실행
____고가용성 설정
__플링크 내부의 데이터 전송
____크레딧 기반 흐름 제어
____태스크 체이닝
__이벤트 시간 처리
____타임스탬프
____워터마크
____워터마크 전파와 이벤트 시간
____타임스탬프 할당과 워터마크 생성
__상태 관리
____연산자 상태
____키 상태
____상태 백엔드
____상태가 있는 연산자의 수평 확장
__체크포인트, 세이브포인트, 상태 복구
____일관성 체크포인트
____일관성 체크포인트에서 복구
____플링크의 체크포인트 알고리즘
____체크포인트가 성능에 미치는 영향
____세이브포인트
__요약


4장. 아파치 플링크 개발 환경 설치
__소프트웨어 요구 사항
__IDE에서 플링크 애플리케이션 실행과 디버깅
____IDE에서 예제 코드 불러오기
____IDE에서 플링크 애플리케이션 실행
____IDE에서 플링크 애플리케이션 디버깅
__플링크 메이븐 프로젝트 부트스트랩
__요약


5장. DataStream API(v1.7)
__헬로우, 플링크!
____실행 환경 설정
____입력 스트림 읽기
____변환 연산 적용
____결과 출력
____실행
__변환 연산
____기본 변환 연산
____KeyedStream 변환 연산
____다중 스트림 변환 연산
____분산 변환 연산
__병렬 설정
__데이터 타입
____지원하는 데이터 타입
____TypeInformation 생성
____명시적인 TypeInformation 제공
__키 정의 방법과 필드 참조
____필드 위치
____필드 표현식
____Key Selector
__함수 구현
____함수 클래스
____람다 함수
____RichFunction
__외부 의존 라이브러리와 플링크 라이브러리 포함
__요약


6장. 시간 기반 연산자와 윈도우 연산자
__시간 특성 설정
____타임스탬프 할당과 워터마크 생성
____워터마크가 지연과 완성도에 미치는 영향
__ProcessFunction
____TimerService와 타이머
____사이드 출력으로 내보내기
____CoProcessFunction
__윈도우 연산자
____윈도우 연산자 정의
____기본 윈도우 할당자
____윈도우에 함수 적용
____사용자 정의 윈도우 연산자
__시간 기반 스트림 조인
____간격 조인
____윈도우 조인
__연착 데이터 처리
____연착 이벤트 버리기
____연착 이벤트 재전송
____연착 이벤트를 포함해 처리 결과 갱신
____요약


7장. 상태가 있는 연산자와 애플리케이션
__상태가 있는 함수 구현
____RuntimeContext에 키 상태 선언
____ListCheckpointed 인터페이스를 이용해 연산자 리스트 상태 구현
____브로드캐스트 상태 사용
____CheckpointedFunction 인터페이스 사용
____체크포인트 완료 알림 받기
__상태가 있는 애플리케이션의 장애 복구 활성화
__상태가 있는 애플리케이션의 유지 보수 활성화
____연산자 고유 식별자 지정
____키 상태 연산자에 최대 병렬 값 정의
__상태가 있는 애플리케이션의 성능과 견고함
____상태 백엔드 선택
____기본 상태 종류 선택
____상태 누수 방지
__상태가 있는 애플리케이션의 진화
____기존 상태 수정 없이 애플리케이션 갱신
____애플리케이션에서 상태 제거
____연산자의 상태 변경
__쿼리 가능한 상태
____쿼리 가능한 상태의 아키텍처와 쿼리 가능한 상태 활성화
____쿼리 가능한 상태 노출
____외부 애플리케이션에서 상태 쿼리
__요약


8장. 외부 시스템 연동
__애플리케이션 일관성 보장
____멱등적 쓰기
____트랜잭션 쓰기
__기본 제공 커넥터
____아파치 카프카 소스 커넥터
____아파치 카프카 싱크 커넥터
____파일 시스템 소스 커넥터
____파일 시스템 싱크 커넥터
____아파치 카산드라 싱크 커넥터
__사용자 정의 소스 함수 구현
____재설정 가능한 소스 함수
____SourceFunction, 타임스탬프, 워터마크
__사용자 정의 싱크 함수 구현
____멱등적 싱크 커넥터
____트랜잭션 싱크 커넥터
__비동기로 외부 시스템에 접근
__요약


9장. 플링크 설치
__배치 모드
____독립형 클러스터
____도커
____아파치 하둡 YARN
____쿠버네티스
__고가용성 설정
____고가용성 독립형 설정
____고가용성 YARN 설정
____고가용성 쿠버네티스 설치
__하둡 컴포넌트와 통합
__파일 시스템 설정
__시스템 환경설정
____자바와 클래스 로딩
____CPU
____메인메모리와 네트워크 버퍼
____디스크 저장소
____체크포인트와 상태 백엔드
____보안
__요약


10장. 플링크와 스트리밍 애플리케이션 운영
__스트리밍 애플리케이션 실행과 관리
____세이브포인트
____커맨드라인 클라이언트로 애플리케이션 관리
____REST API로 애플리케이션 관리
____애플리케이션을 컨테이너로 번들링하고 배치
__태스크 스케줄 제어
____태스크 체이닝 제어
____슬롯 공유 그룹 정의
__체크포인팅과 복구 튜닝
____체크포인팅 설정
____상태 백엔드 설정
____복구 설정
__플링크 클러스터와 애플리케이션 모니터링
____플링크 웹 UI
____메트릭 시스템
____지연 모니터링
__로깅 설정
__요약


11장. 새 여정의 시작
__스트리밍 처리 외의 플링크 생태계
____DataSet API로 배치 처리
____Table API와 SQL로 관계형 데이터 분석
____FlinkCEP로 복합 이벤트 처리와 패턴 매칭
____그래프 처리를 위한 Gelly
__커뮤니티 소개