join hint
-
DataSet Join 예제flink 2021. 5. 15. 20:34
문제 person 파일 (id, name) 과 location 파일 (id, city) 을 left outer join 해 output 파일에 저장한다. Person 파일 (person.txt) 1,John 2,Albert 3,Lui 4,Smith 5,Robert Location 파일 (location.txt) 1,DC 2,NY 4,LA 6,LU 7,DL 8,NH Expected Output 1 Some(John) Some(DC) 2 Some(Albert) Some(NY) 3 Some(Lui) None 4 Some(Smith) Some(LA) 5 Some(Robert) None Code import org.apache.flink.api.common.operators.base.JoinOperatorBase..