org.apache.flink.client.deployment.application

类 ClassPathPackagedProgramRetriever

java.lang.Object

org.apache.flink.client.deployment.application.ClassPathPackagedProgramRetriever

所有已实现的接口:

PackagedProgramRetriever

@Internal
public class ClassPathPackagedProgramRetriever
extends Object
implements PackagedProgramRetriever

A PackagedProgramRetriever which creates the PackagedProgram containing the user's main() from a class on the class path.

嵌套类概要

嵌套类

限定符和类型	类和说明
static class	ClassPathPackagedProgramRetriever.Builder A builder for the ClassPathPackagedProgramRetriever.

方法概要

限定符和类型	方法和说明
PackagedProgram	getPackagedProgram() Retrieve the PackagedProgram.
static ClassPathPackagedProgramRetriever.Builder	newBuilder(String[] programArguments)

从类继承的方法 java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

方法详细资料

getPackagedProgram

public PackagedProgram getPackagedProgram()
                                   throws org.apache.flink.util.FlinkException

从接口复制的说明: PackagedProgramRetriever

Retrieve the PackagedProgram.

指定者:

getPackagedProgram 在接口中 PackagedProgramRetriever

返回:

the retrieved PackagedProgram.

抛出:

org.apache.flink.util.FlinkException - if the PackagedProgram could not be retrieved

newBuilder

public static ClassPathPackagedProgramRetriever.Builder newBuilder(String[] programArguments)