분류 전체보기5 Flink 훑어보기 flink ? "플링크는 구분된 데이터(bounded data) 및 연속 데이터(unbounded data) 스트림에 대해 stateful 하게 처리하기 위한 프레임워크 (분산 처리 엔진)이다" 알아듣기 쉽게 말하면, 스트림 형태로 계속 오는 데이터들을 다루는데 강점이 있는 프레임워크다. 또한, 데이터를 단순히 처리하고 흘려보내는 것이 아니라, 상태를 저장하고 컨트롤이 가능하다. 어렵게 생각하지 말고 일단 코드를 차근차근 보자. object Handler { def handle[E { //걸러낸다 }) .map((o: PredefinedMessage) => { //무언가를 한다 }) .keyBy( (o: Tuple2[Useridentifier, CustomLog1]) => { //그룹화 시킨다 o.f0... 2020. 11. 20. 이전 1 2 다음