multiple consumer of intermediate data set

2017-03-12 Thread 윤형덕
Hi All, figure1 https://ci.apache.org/projects/flink/flink-docs-release-1.2/fig/job_and_execution_graph.svg as we can see in figure1, JobVertex(B) has two consumer( JobVertex(C) and JobVertex(D) ) and accordingly Intermediate Data Set of JobVertex(B) has two consumer( JobVertex(C) and JobVert

Re: inheritance of Program interface in Program.java in org.apache.flink.api.common

2016-05-20 Thread 윤형덕
omProgram(this.program, this.args); } return this.plan; } -Original Message- From: "Ufuk Celebi"<u...@apache.org> To: <user@flink.apache.org>; "윤형덕"<ynoo...@naver.com>; Cc: Sent: 2016-05-20 (금) 19:30:01 Subject: Re: inheritance of Program interf

inheritance of Program interface in Program.java in org.apache.flink.api.common

2016-05-19 Thread 윤형덕
hello first I'm sorry for my poor english. I were looking at PackagedProgram.java from org.apache.flink.client.program and in following cunstructor: PackagedProgram(File jarFile, List classpaths, String entryPointClassName, String... args) there is some code I couldn't understand. please look