동등한 RDD ForEach of Flark Flick에서

Question

아파치 스파크에서 우리는 여러 번 RDD forEach를 사용하여 RDD의 각 데이터를 평가하거나 처리합니다 ... Apache Flink에서 동일한 내용을 알고 싶습니까 ??

Answer 1

Flink에는 해당 항목이 없습니다. 그러나 map()을 사용하고 거기에 사용자 정의 함수를 넣을 수 있습니다.

1. RDDs는 스파크 개념이다 - FLINK은 데이터 스트림에서 작동 않습니다
   그냥 명확하게.
2. forEach
, 당신은 "부작용과 정체성"기능을 넣어해야하는 각 요소의 함수를 호출하지만, FLINK에 map()를 사용하여 (기본 데이터를 수정하지 않습니다 - 즉,지도의 UDF이해야 할 무엇 대해 forEach UDF 플러스 변성 입력 레코드를 방출 않는다.)

Answer 2

버전 1.2 FLINK 때문에 것은 각 스트림 소자 요구된다는 점에서, 점화에 forEach에 다소 유사하다 ProcessFunction을 제공한다.