我在org.apache.flink.client.program和以下构造函数中查看了packagedprogram.java:
PackagedProgram(File jarFile, List<URL> classpaths, String entryPointClassName, String... args)
有些代码我不懂;请看下面:
this.mainClass = loadMainClass(entryPointClassName, userCodeClassLoader);
if (Program.class.isAssignableFrom(this.mainClass)) {
Program prg = null;
try {
prg = InstantiationUtil.instantiate(this.mainClass.asSubclass(Program.class), Program.class);
}
你怎么能 this.mainClass
它不重写getplan方法,getplan方法是程序接口(program.class)的抽象方法,并且只有静态main方法被示例化为program?
暂无答案!
目前还没有任何答案,快来回答吧!