| 接口 | 说明 |
|---|---|
| ApplicationRunner |
An interface to be implemented by the entities responsible for application
submission for the different deployment environments.
|
| 类 | 说明 |
|---|---|
| ApplicationClusterEntryPoint |
Base class for cluster entry points targeting executing applications in "Application Mode".
|
| ApplicationConfiguration |
Application-specific configurations.
|
| ApplicationDispatcherBootstrap |
A
DispatcherBootstrap used for running the user's main() in "Application Mode" (see FLIP-85). |
| ApplicationDispatcherGatewayServiceFactory |
A
DispatcherGatewayServiceFactory used when executing a job in Application Mode, i.e. the user's main is executed on
the same machine as the Dispatcher and the lifecycle of the cluster is the same as the one of the application. |
| ApplicationDispatcherLeaderProcessFactoryFactory |
Factory for a
DispatcherLeaderProcessFactoryFactory designed to be used when executing
an application in Application Mode. |
| ClassPathPackagedProgramRetriever |
A
PackagedProgramRetriever
which creates the PackagedProgram containing
the user's main() from a class on the class path. |
| ClassPathPackagedProgramRetriever.Builder |
A builder for the
ClassPathPackagedProgramRetriever. |
| DetachedApplicationRunner |
An
ApplicationRunner which runs the user specified application using the EmbeddedExecutor. |
| EmbeddedJobClient |
A
JobClient with the ability to also submit jobs which
uses directly the DispatcherGateway. |
| WebSubmissionJobClient |
A
JobClient that only allows asking for the job id of the job it is attached to. |
| 异常错误 | 说明 |
|---|---|
| ApplicationExecutionException |
A
FlinkException thrown in case something during application execution went wrong. |
Copyright © 2014–2020 The Apache Software Foundation. All rights reserved.