索引 (flink-clients 1.11.2 API)

A B C D E F G H I K L M N O P R S T U V W Y Z

A

AbstractContainerizedClusterClientFactory<ClusterID> - org.apache.flink.client.deployment中的类: An abstract ClusterClientFactory containing some common implementations for different containerized deployment clusters.
AbstractContainerizedClusterClientFactory() - 类的构造器org.apache.flink.client.deployment.AbstractContainerizedClusterClientFactory
AbstractCustomCommandLine - org.apache.flink.client.cli中的类: Base class for CustomCommandLine implementations which specify a JobManager address and a ZooKeeper namespace.
AbstractCustomCommandLine(Configuration) - 类的构造器org.apache.flink.client.cli.AbstractCustomCommandLine
AbstractJobClusterExecutor<ClusterID,ClientFactory extends ClusterClientFactory<ClusterID>> - org.apache.flink.client.deployment.executors中的类: An abstract PipelineExecutor used to execute pipelines on dedicated (per-job) clusters.
AbstractJobClusterExecutor(ClientFactory) - 类的构造器org.apache.flink.client.deployment.executors.AbstractJobClusterExecutor
AbstractSessionClusterExecutor<ClusterID,ClientFactory extends ClusterClientFactory<ClusterID>> - org.apache.flink.client.deployment.executors中的类: An abstract PipelineExecutor used to execute pipelines on an existing (session) cluster.
AbstractSessionClusterExecutor(ClientFactory) - 类的构造器org.apache.flink.client.deployment.executors.AbstractSessionClusterExecutor
addGeneralOptions(Options) - 类中的方法org.apache.flink.client.cli.AbstractCustomCommandLine
addGeneralOptions(Options) - 接口中的方法org.apache.flink.client.cli.CustomCommandLine: Adds custom options to the existing general options.
addGeneralOptions(Options) - 类中的方法org.apache.flink.client.cli.DefaultCLI
addGeneralOptions(Options) - 类中的方法org.apache.flink.client.cli.GenericCLI
ADDRESS_OPTION - 类中的静态变量org.apache.flink.client.cli.CliFrontendParser
addressOption - 类中的变量org.apache.flink.client.cli.AbstractCustomCommandLine
addRunOptions(Options) - 类中的方法org.apache.flink.client.cli.AbstractCustomCommandLine
addRunOptions(Options) - 接口中的方法org.apache.flink.client.cli.CustomCommandLine: Adds custom options to the existing run options.
addRunOptions(Options) - 类中的方法org.apache.flink.client.cli.GenericCLI
APPLICATION_ARGS - 类中的静态变量org.apache.flink.client.deployment.application.ApplicationConfiguration
APPLICATION_MAIN_CLASS - 类中的静态变量org.apache.flink.client.deployment.application.ApplicationConfiguration
ApplicationClusterDeployer - org.apache.flink.client.deployment.application.cli中的类: An entity responsible for submitting an application for execution in "Application Mode", i.e. on a dedicated cluster that is created on application submission and torn down upon application termination, and with its main() executed on the cluster, rather than the client.
ApplicationClusterDeployer(ClusterClientServiceLoader) - 类的构造器org.apache.flink.client.deployment.application.cli.ApplicationClusterDeployer
ApplicationClusterEntryPoint - org.apache.flink.client.deployment.application中的类: Base class for cluster entry points targeting executing applications in "Application Mode".
ApplicationClusterEntryPoint(Configuration, PackagedProgram, ResourceManagerFactory<?>) - 类的构造器org.apache.flink.client.deployment.application.ApplicationClusterEntryPoint
ApplicationConfiguration - org.apache.flink.client.deployment.application中的类: Application-specific configurations.
ApplicationConfiguration(String[], String) - 类的构造器org.apache.flink.client.deployment.application.ApplicationConfiguration
ApplicationDeployer - org.apache.flink.client.cli中的接口: An interface to be used by the CliFrontend to submit user programs for execution.
ApplicationDispatcherBootstrap - org.apache.flink.client.deployment.application中的类: A DispatcherBootstrap used for running the user's main() in "Application Mode" (see FLIP-85).
ApplicationDispatcherBootstrap(PackagedProgram, Collection<JobGraph>, Configuration) - 类的构造器org.apache.flink.client.deployment.application.ApplicationDispatcherBootstrap
ApplicationDispatcherGatewayServiceFactory - org.apache.flink.client.deployment.application中的类: 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.
ApplicationDispatcherGatewayServiceFactory(Configuration, DispatcherFactory, PackagedProgram, RpcService, PartialDispatcherServices) - 类的构造器org.apache.flink.client.deployment.application.ApplicationDispatcherGatewayServiceFactory
ApplicationDispatcherLeaderProcessFactoryFactory - org.apache.flink.client.deployment.application中的类: Factory for a DispatcherLeaderProcessFactoryFactory designed to be used when executing an application in Application Mode.
ApplicationExecutionException - org.apache.flink.client.deployment.application中的异常错误: A FlinkException thrown in case something during application execution went wrong.
ApplicationExecutionException(String) - 异常错误的构造器org.apache.flink.client.deployment.application.ApplicationExecutionException
ApplicationExecutionException(Throwable) - 异常错误的构造器org.apache.flink.client.deployment.application.ApplicationExecutionException
ApplicationExecutionException(String, Throwable) - 异常错误的构造器org.apache.flink.client.deployment.application.ApplicationExecutionException
ApplicationRunner - org.apache.flink.client.deployment.application中的接口: An interface to be implemented by the entities responsible for application submission for the different deployment environments.
applyCommandLineOptionsToConfiguration(CommandLine) - 类中的方法org.apache.flink.client.cli.AbstractCustomCommandLine
applyCommandLineOptionsToConfiguration(CommandLine) - 接口中的方法org.apache.flink.client.cli.CustomCommandLine: Override configuration settings by specified command line options.
applyCommandLineOptionsToConfiguration(CommandLine) - 类中的方法org.apache.flink.client.cli.GenericCLI
applyToConfiguration(Configuration) - 类中的方法org.apache.flink.client.cli.ExecutionConfigAccessor
applyToConfiguration(Configuration) - 类中的方法org.apache.flink.client.cli.ProgramOptions
applyToConfiguration(Configuration) - 类中的方法org.apache.flink.client.deployment.application.ApplicationConfiguration
ARGS_OPTION - 类中的静态变量org.apache.flink.client.cli.CliFrontendParser

B

build() - 类中的方法org.apache.flink.client.deployment.application.ClassPathPackagedProgramRetriever.Builder
build() - 类中的方法org.apache.flink.client.program.PackagedProgram.Builder
buildUserCodeClassLoader(List<URL>, List<URL>, ClassLoader, Configuration) - 枚举中的静态方法org.apache.flink.client.ClientUtils

C

cancel(String[]) - 类中的方法org.apache.flink.client.cli.CliFrontend: Executes the CANCEL action.
cancel() - 类中的方法org.apache.flink.client.deployment.application.EmbeddedJobClient
cancel() - 类中的方法org.apache.flink.client.deployment.application.WebSubmissionJobClient
cancel() - 类中的方法org.apache.flink.client.deployment.ClusterClientJobClientAdapter
cancel(JobID) - 接口中的方法org.apache.flink.client.program.ClusterClient: Cancels a job identified by the job id.
cancel(JobID) - 类中的方法org.apache.flink.client.program.MiniClusterClient
cancel(JobID) - 类中的方法org.apache.flink.client.program.rest.RestClusterClient
CancelOptions - org.apache.flink.client.cli中的类: Command line options for the CANCEL command.
CancelOptions(CommandLine) - 类的构造器org.apache.flink.client.cli.CancelOptions
cancelWithSavepoint(JobID, String) - 接口中的方法org.apache.flink.client.program.ClusterClient: Cancels a job identified by the job id and triggers a savepoint.
cancelWithSavepoint(JobID, String) - 类中的方法org.apache.flink.client.program.MiniClusterClient
cancelWithSavepoint(JobID, String) - 类中的方法org.apache.flink.client.program.rest.RestClusterClient
canTranslate(Pipeline) - 接口中的方法org.apache.flink.client.FlinkPipelineTranslator
canTranslate(Pipeline) - 类中的方法org.apache.flink.client.PlanTranslator
canTranslate(Pipeline) - 类中的方法org.apache.flink.client.StreamGraphTranslator
ClassPathPackagedProgramRetriever - org.apache.flink.client.deployment.application中的类: A PackagedProgramRetriever which creates the PackagedProgram containing the user's main() from a class on the class path.
ClassPathPackagedProgramRetriever.Builder - org.apache.flink.client.deployment.application中的类: A builder for the ClassPathPackagedProgramRetriever.
CliArgsException - org.apache.flink.client.cli中的异常错误: Special exception that is thrown when the command line parsing fails.
CliArgsException(String) - 异常错误的构造器org.apache.flink.client.cli.CliArgsException
CliArgsException(String, Throwable) - 异常错误的构造器org.apache.flink.client.cli.CliArgsException
CLIENT_RETRY_PERIOD - 类中的静态变量org.apache.flink.client.cli.ClientOptions
CLIENT_TIMEOUT - 类中的静态变量org.apache.flink.client.cli.ClientOptions
ClientOptions - org.apache.flink.client.cli中的类: Describes a client configuration parameter.
ClientOptions() - 类的构造器org.apache.flink.client.cli.ClientOptions
ClientUtils - org.apache.flink.client中的枚举: Utility functions for Flink client.
CliFrontend - org.apache.flink.client.cli中的类: Implementation of a simple command line frontend for executing programs.
CliFrontend(Configuration, List<CustomCommandLine>) - 类的构造器org.apache.flink.client.cli.CliFrontend
CliFrontend(Configuration, ClusterClientServiceLoader, List<CustomCommandLine>) - 类的构造器org.apache.flink.client.cli.CliFrontend
CliFrontendParser - org.apache.flink.client.cli中的类: A simple command line parser (based on Apache Commons CLI) that extracts command line options.
CliFrontendParser() - 类的构造器org.apache.flink.client.cli.CliFrontendParser
close() - 接口中的方法org.apache.flink.client.deployment.ClusterDescriptor
close() - 类中的方法org.apache.flink.client.deployment.StandaloneClusterDescriptor
close() - 接口中的方法org.apache.flink.client.program.ClusterClient
close() - 类中的方法org.apache.flink.client.program.MiniClusterClient
close() - 类中的方法org.apache.flink.client.program.rest.RestClusterClient
ClusterClient<T> - org.apache.flink.client.program中的接口: Encapsulates the functionality necessary to submit a program to a remote cluster.
ClusterClientFactory<ClusterID> - org.apache.flink.client.deployment中的接口: A factory containing all the necessary information for creating clients to Flink clusters.
ClusterClientJobClientAdapter<ClusterID> - org.apache.flink.client.deployment中的类: An implementation of the JobClient interface that uses a ClusterClient underneath..
ClusterClientJobClientAdapter(ClusterClientProvider<ClusterID>, JobID) - 类的构造器org.apache.flink.client.deployment.ClusterClientJobClientAdapter
ClusterClientProvider<T> - org.apache.flink.client.program中的接口: Factory for ClusterClients.
ClusterClientServiceLoader - org.apache.flink.client.deployment中的接口: An interface used to discover the appropriate cluster client factory based on the provided Configuration.
ClusterDeploymentException - org.apache.flink.client.deployment中的异常错误: Class which indicates a problem when deploying a Flink cluster.
ClusterDeploymentException(String) - 异常错误的构造器org.apache.flink.client.deployment.ClusterDeploymentException
ClusterDeploymentException(Throwable) - 异常错误的构造器org.apache.flink.client.deployment.ClusterDeploymentException
ClusterDeploymentException(String, Throwable) - 异常错误的构造器org.apache.flink.client.deployment.ClusterDeploymentException
ClusterDescriptor<T> - org.apache.flink.client.deployment中的接口: A descriptor to deploy a cluster (e.g.
ClusterRetrieveException - org.apache.flink.client.deployment中的异常错误: Exception which indicates that a cluster could not be retrieved.
ClusterRetrieveException(String) - 异常错误的构造器org.apache.flink.client.deployment.ClusterRetrieveException
ClusterRetrieveException(Throwable) - 异常错误的构造器org.apache.flink.client.deployment.ClusterRetrieveException
ClusterRetrieveException(String, Throwable) - 异常错误的构造器org.apache.flink.client.deployment.ClusterRetrieveException
ClusterSpecification - org.apache.flink.client.deployment中的类: Description of the cluster to start by the ClusterDescriptor.
ClusterSpecification.ClusterSpecificationBuilder - org.apache.flink.client.deployment中的类: Builder for the ClusterSpecification instance.
ClusterSpecificationBuilder() - 类的构造器org.apache.flink.client.deployment.ClusterSpecification.ClusterSpecificationBuilder
CommandLineOptions - org.apache.flink.client.cli中的类: Base class for all options parsed from the command line.
CommandLineOptions(CommandLine) - 类的构造器org.apache.flink.client.cli.CommandLineOptions
configuration - 类中的变量org.apache.flink.client.cli.AbstractCustomCommandLine
configureExecution(Configuration, PackagedProgram) - 类中的静态方法org.apache.flink.client.deployment.application.ApplicationClusterEntryPoint
containsPythonDependencyOptions(CommandLine) - 枚举中的静态方法org.apache.flink.client.cli.ProgramOptionsUtils
ContextEnvironment - org.apache.flink.client.program中的类: Execution Environment for remote execution with the Client.
ContextEnvironment(PipelineExecutorServiceLoader, Configuration, ClassLoader, boolean, boolean) - 类的构造器org.apache.flink.client.program.ContextEnvironment
create(CommandLine) - 类中的静态方法org.apache.flink.client.cli.ProgramOptions
create(DispatcherId, Collection<JobGraph>, JobGraphWriter) - 类中的方法org.apache.flink.client.deployment.application.ApplicationDispatcherGatewayServiceFactory
create(Configuration, DispatcherFactory, PackagedProgram) - 类中的静态方法org.apache.flink.client.deployment.application.ApplicationDispatcherLeaderProcessFactoryFactory
create(Configuration) - 类中的静态方法org.apache.flink.client.deployment.executors.LocalExecutor
create() - 类中的静态方法org.apache.flink.client.program.PerJobMiniClusterFactory
createClusterDescriptor(Configuration) - 接口中的方法org.apache.flink.client.deployment.ClusterClientFactory: Create a ClusterDescriptor from the given configuration.
createClusterDescriptor(Configuration) - 类中的方法org.apache.flink.client.deployment.StandaloneClientFactory
createClusterSpecification() - 类中的方法org.apache.flink.client.deployment.ClusterSpecification.ClusterSpecificationBuilder
createDispatcherResourceManagerComponentFactory(Configuration) - 类中的方法org.apache.flink.client.deployment.application.ApplicationClusterEntryPoint
createFactory(JobGraphStoreFactory, Executor, RpcService, PartialDispatcherServices, FatalErrorHandler) - 类中的方法org.apache.flink.client.deployment.application.ApplicationDispatcherLeaderProcessFactoryFactory
createJobGraph(PackagedProgram, Configuration, int, JobID, boolean) - 枚举中的静态方法org.apache.flink.client.program.PackagedProgramUtils: Creates a JobGraph with a specified JobID from the given PackagedProgram.
createJobGraph(PackagedProgram, Configuration, int, boolean) - 枚举中的静态方法org.apache.flink.client.program.PackagedProgramUtils: Creates a JobGraph with a random JobID from the given PackagedProgram.
createPythonProgramOptions(CommandLine) - 枚举中的静态方法org.apache.flink.client.cli.ProgramOptionsUtils
createSavepointRestoreSettings(CommandLine) - 类中的静态方法org.apache.flink.client.cli.CliFrontendParser
createSerializableExecutionGraphStore(Configuration, ScheduledExecutor) - 类中的方法org.apache.flink.client.deployment.application.ApplicationClusterEntryPoint
createWithFactory(Configuration, Function<MiniClusterConfiguration, MiniCluster>) - 类中的静态方法org.apache.flink.client.deployment.executors.LocalExecutor
createWithFactory(Configuration, Function<? super MiniClusterConfiguration, ? extends MiniCluster>) - 类中的静态方法org.apache.flink.client.program.PerJobMiniClusterFactory
CustomCommandLine - org.apache.flink.client.cli中的接口: Custom command-line interface to load hooks for the command-line interface.

D

DefaultCLI - org.apache.flink.client.cli中的类: The default CLI which is used for interaction with standalone clusters.
DefaultCLI(Configuration) - 类的构造器org.apache.flink.client.cli.DefaultCLI
DefaultClusterClientServiceLoader - org.apache.flink.client.deployment中的类: A service provider for cluster client factories.
DefaultClusterClientServiceLoader() - 类的构造器org.apache.flink.client.deployment.DefaultClusterClientServiceLoader
deleteExtractedLibraries() - 类中的方法org.apache.flink.client.program.PackagedProgram: Deletes all temporary files created for contained packaged libraries.
deployApplicationCluster(ClusterSpecification, ApplicationConfiguration) - 接口中的方法org.apache.flink.client.deployment.ClusterDescriptor: Triggers deployment of an application cluster.
deployApplicationCluster(ClusterSpecification, ApplicationConfiguration) - 类中的方法org.apache.flink.client.deployment.StandaloneClusterDescriptor
deployJobCluster(ClusterSpecification, JobGraph, boolean) - 接口中的方法org.apache.flink.client.deployment.ClusterDescriptor: Deploys a per-job cluster with the given job on the cluster.
deployJobCluster(ClusterSpecification, JobGraph, boolean) - 类中的方法org.apache.flink.client.deployment.StandaloneClusterDescriptor
deploySessionCluster(ClusterSpecification) - 接口中的方法org.apache.flink.client.deployment.ClusterDescriptor: Triggers deployment of a cluster.
deploySessionCluster(ClusterSpecification) - 类中的方法org.apache.flink.client.deployment.StandaloneClusterDescriptor
DETACHED_OPTION - 类中的静态变量org.apache.flink.client.cli.CliFrontendParser
DetachedApplicationRunner - org.apache.flink.client.deployment.application中的类: An ApplicationRunner which runs the user specified application using the EmbeddedExecutor.
DetachedApplicationRunner(boolean) - 类的构造器org.apache.flink.client.deployment.application.DetachedApplicationRunner
disposeSavepoint(String) - 接口中的方法org.apache.flink.client.program.ClusterClient: Dispose the savepoint under the given path.
disposeSavepoint(String) - 类中的方法org.apache.flink.client.program.MiniClusterClient
disposeSavepoint(String) - 类中的方法org.apache.flink.client.program.rest.RestClusterClient

E

EmbeddedExecutor - org.apache.flink.client.deployment.application.executors中的类: A base class for executors that invoke directly methods of the Dispatcher and do not go through the REST API.
EmbeddedExecutor(Collection<JobID>, DispatcherGateway, EmbeddedJobClientCreator) - 类的构造器org.apache.flink.client.deployment.application.executors.EmbeddedExecutor: Creates a EmbeddedExecutor.
EmbeddedExecutorFactory - org.apache.flink.client.deployment.application.executors中的类: An PipelineExecutorFactory for the EmbeddedExecutor.
EmbeddedExecutorFactory(Collection<JobID>, DispatcherGateway, ScheduledExecutor) - 类的构造器org.apache.flink.client.deployment.application.executors.EmbeddedExecutorFactory: Creates an EmbeddedExecutorFactory.
EmbeddedExecutorServiceLoader - org.apache.flink.client.deployment.application.executors中的类: A PipelineExecutorServiceLoader that always returns an EmbeddedExecutorFactory.
EmbeddedExecutorServiceLoader(Collection<JobID>, DispatcherGateway, ScheduledExecutor) - 类的构造器org.apache.flink.client.deployment.application.executors.EmbeddedExecutorServiceLoader: Creates an EmbeddedExecutorServiceLoader.
EmbeddedJobClient - org.apache.flink.client.deployment.application中的类: A JobClient with the ability to also submit jobs which uses directly the DispatcherGateway.
EmbeddedJobClient(JobID, DispatcherGateway, ScheduledExecutor, Time) - 类的构造器org.apache.flink.client.deployment.application.EmbeddedJobClient
EmbeddedJobClientCreator - org.apache.flink.client.deployment.application.executors中的接口: An interface to be implemented by JobClient suppliers.
entryPointClass - 类中的变量org.apache.flink.client.cli.ProgramOptions
execute(Pipeline, Configuration) - 类中的方法org.apache.flink.client.deployment.application.executors.EmbeddedExecutor
execute(Pipeline, Configuration) - 类中的方法org.apache.flink.client.deployment.executors.AbstractJobClusterExecutor
execute(Pipeline, Configuration) - 类中的方法org.apache.flink.client.deployment.executors.AbstractSessionClusterExecutor
execute(Pipeline, Configuration) - 类中的方法org.apache.flink.client.deployment.executors.LocalExecutor
execute(String) - 类中的方法org.apache.flink.client.program.ContextEnvironment
execute(StreamGraph) - 类中的方法org.apache.flink.client.program.StreamContextEnvironment
executeAsync(String) - 类中的方法org.apache.flink.client.program.ContextEnvironment
executeAsync(String) - 类中的方法org.apache.flink.client.program.OptimizerPlanEnvironment
executeAsync(StreamGraph) - 类中的方法org.apache.flink.client.program.StreamContextEnvironment
executeAsync(StreamGraph) - 类中的方法org.apache.flink.client.program.StreamPlanEnvironment
executeProgram(Configuration, PackagedProgram) - 类中的方法org.apache.flink.client.cli.CliFrontend
executeProgram(PipelineExecutorServiceLoader, Configuration, PackagedProgram, boolean, boolean) - 枚举中的静态方法org.apache.flink.client.ClientUtils
ExecutionConfigAccessor - org.apache.flink.client.cli中的类: Accessor that exposes config settings that are relevant for execution from an underlying Configuration.
ExponentialWaitStrategy - org.apache.flink.client.program.rest.retry中的类: WaitStrategy with exponentially increasing sleep time.
ExponentialWaitStrategy(long, long) - 类的构造器org.apache.flink.client.program.rest.retry.ExponentialWaitStrategy
extractContainedLibraries(URL) - 类中的静态方法org.apache.flink.client.program.PackagedProgram: Takes all JAR files that are contained in this program's JAR file and extracts them to the system's temp directory.
extractProgramArgs(CommandLine) - 类中的方法org.apache.flink.client.cli.ProgramOptions

F

FlinkPipelineTranslationUtil - org.apache.flink.client中的类: Utility for transforming FlinkPipelines into a JobGraph.
FlinkPipelineTranslationUtil() - 类的构造器org.apache.flink.client.FlinkPipelineTranslationUtil
FlinkPipelineTranslator - org.apache.flink.client中的接口: This can be used to turn a Pipeline into a JobGraph.
fromConfiguration(Configuration) - 类中的静态方法org.apache.flink.client.cli.ExecutionConfigAccessor: Creates an ExecutionConfigAccessor based on the provided Configuration.
fromConfiguration(Configuration) - 类中的静态方法org.apache.flink.client.deployment.application.ApplicationConfiguration
fromConfiguration(Configuration) - 类中的静态方法org.apache.flink.client.program.rest.RestClusterClientConfiguration
fromProgramOptions(ProgramOptions, List<T>) - 类中的静态方法org.apache.flink.client.cli.ExecutionConfigAccessor: Creates an ExecutionConfigAccessor based on the provided ProgramOptions as provided by the user through the CLI.

G

GenericCLI - org.apache.flink.client.cli中的类: A generic implementation of the CustomCommandLine that only expects the execution.target parameter to be explicitly specified and simply forwards the rest of the options specified with -D to the corresponding PipelineExecutor for further parsing.
GenericCLI(Configuration, String) - 类的构造器org.apache.flink.client.cli.GenericCLI
getAccumulators(ClassLoader) - 类中的方法org.apache.flink.client.deployment.application.EmbeddedJobClient
getAccumulators(ClassLoader) - 类中的方法org.apache.flink.client.deployment.application.WebSubmissionJobClient
getAccumulators(ClassLoader) - 类中的方法org.apache.flink.client.deployment.ClusterClientJobClientAdapter
getAccumulators(JobID) - 接口中的方法org.apache.flink.client.program.ClusterClient: Requests and returns the accumulators for the given job identifier.
getAccumulators(JobID, ClassLoader) - 接口中的方法org.apache.flink.client.program.ClusterClient: Requests and returns the accumulators for the given job identifier.
getAccumulators(JobID, ClassLoader) - 类中的方法org.apache.flink.client.program.MiniClusterClient
getAccumulators(JobID, ClassLoader) - 类中的方法org.apache.flink.client.program.rest.RestClusterClient
getApplicationClassName() - 类中的方法org.apache.flink.client.deployment.application.ApplicationConfiguration
getArgs() - 类中的方法org.apache.flink.client.cli.CancelOptions
getArgs() - 类中的方法org.apache.flink.client.cli.SavepointOptions
getArguments() - 类中的方法org.apache.flink.client.program.PackagedProgram
getAwaitLeaderTimeout() - 类中的方法org.apache.flink.client.program.rest.RestClusterClientConfiguration
getClasspaths() - 类中的方法org.apache.flink.client.cli.ExecutionConfigAccessor
getClasspaths() - 类中的方法org.apache.flink.client.cli.ProgramOptions
getClasspaths() - 类中的方法org.apache.flink.client.program.PackagedProgram: Returns the classpaths that are required by the program.
getClusterClient() - 接口中的方法org.apache.flink.client.program.ClusterClientProvider: Creates and returns a new ClusterClient.
getClusterClientFactory(Configuration) - 接口中的方法org.apache.flink.client.deployment.ClusterClientServiceLoader: Discovers the appropriate ClusterClientFactory based on the provided configuration.
getClusterClientFactory(Configuration) - 类中的方法org.apache.flink.client.deployment.DefaultClusterClientServiceLoader
getClusterDescription() - 接口中的方法org.apache.flink.client.deployment.ClusterDescriptor: Returns a String containing details about the cluster (NodeManagers, available memory, ...).
getClusterDescription() - 类中的方法org.apache.flink.client.deployment.StandaloneClusterDescriptor
getClusterId(Configuration) - 接口中的方法org.apache.flink.client.deployment.ClusterClientFactory: Returns the cluster id if a cluster id is specified in the provided configuration, otherwise it returns null.
getClusterId(Configuration) - 类中的方法org.apache.flink.client.deployment.StandaloneClientFactory
getClusterId() - 接口中的方法org.apache.flink.client.program.ClusterClient: Returns the cluster id identifying the cluster to which the client is connected.
getClusterId() - 类中的方法org.apache.flink.client.program.MiniClusterClient
getClusterId() - 类中的方法org.apache.flink.client.program.rest.RestClusterClient
getClusterSpecification(Configuration) - 类中的方法org.apache.flink.client.deployment.AbstractContainerizedClusterClientFactory
getClusterSpecification(Configuration) - 接口中的方法org.apache.flink.client.deployment.ClusterClientFactory: Returns the ClusterSpecification specified by the configuration and the command line options.
getClusterSpecification(Configuration) - 类中的方法org.apache.flink.client.deployment.StandaloneClientFactory
getCommandLine(Options, String[], boolean) - 类中的方法org.apache.flink.client.cli.CliFrontend
getConfiguration() - 类中的方法org.apache.flink.client.cli.AbstractCustomCommandLine
getConfiguration() - 类中的方法org.apache.flink.client.cli.CliFrontend: Getter which returns a copy of the associated configuration.
getConfigurationDirectoryFromEnv() - 类中的静态方法org.apache.flink.client.cli.CliFrontend
getCustomCommandLineOptions() - 类中的方法org.apache.flink.client.cli.CliFrontend
getDescription() - 类中的方法org.apache.flink.client.program.PackagedProgram: Returns the description provided by the Program class.
getDetachedMode() - 类中的方法org.apache.flink.client.cli.ExecutionConfigAccessor
getDetachedMode() - 类中的方法org.apache.flink.client.cli.ProgramOptions
getEntryPointClassName() - 类中的方法org.apache.flink.client.cli.ProgramOptions
getExecutor(Configuration) - 类中的方法org.apache.flink.client.deployment.application.executors.EmbeddedExecutorFactory
getExecutor(Configuration) - 类中的方法org.apache.flink.client.deployment.application.executors.WebSubmissionExecutorFactory
getExecutor(Configuration) - 类中的方法org.apache.flink.client.deployment.executors.LocalExecutorFactory
getExecutor(Configuration) - 类中的方法org.apache.flink.client.deployment.executors.RemoteExecutorFactory
getExecutorFactory(Configuration) - 类中的方法org.apache.flink.client.deployment.application.executors.EmbeddedExecutorServiceLoader
getExecutorFactory(Configuration) - 类中的方法org.apache.flink.client.deployment.application.executors.WebSubmissionExecutorServiceLoader
getExecutorNames() - 类中的方法org.apache.flink.client.deployment.application.executors.EmbeddedExecutorServiceLoader
getExecutorNames() - 类中的方法org.apache.flink.client.deployment.application.executors.WebSubmissionExecutorServiceLoader
getFlinkConfiguration() - 接口中的方法org.apache.flink.client.program.ClusterClient: Return the Flink configuration object.
getFlinkConfiguration() - 类中的方法org.apache.flink.client.program.MiniClusterClient
getFlinkConfiguration() - 类中的方法org.apache.flink.client.program.rest.RestClusterClient
getId() - 接口中的方法org.apache.flink.client.cli.CustomCommandLine: Gets the unique identifier of this CustomCommandLine.
getId() - 类中的方法org.apache.flink.client.cli.DefaultCLI
getId() - 类中的方法org.apache.flink.client.cli.GenericCLI
getInstance() - 类中的静态方法org.apache.flink.client.deployment.StandaloneClusterId
getJarFilePath() - 类中的方法org.apache.flink.client.cli.ProgramOptions
getJarFilePath() - 类中的方法org.apache.flink.client.cli.SavepointOptions
getJars() - 类中的方法org.apache.flink.client.cli.ExecutionConfigAccessor
getJobClient(JobID) - 接口中的方法org.apache.flink.client.deployment.application.executors.EmbeddedJobClientCreator: Creates a JobClient that is adequate for the context in which the job is executed.
getJobDetails(JobID) - 类中的方法org.apache.flink.client.program.rest.RestClusterClient: Requests the job details.
getJobExecutionResult(ClassLoader) - 类中的方法org.apache.flink.client.deployment.application.EmbeddedJobClient
getJobExecutionResult(ClassLoader) - 类中的方法org.apache.flink.client.deployment.application.WebSubmissionJobClient
getJobExecutionResult(ClassLoader) - 类中的方法org.apache.flink.client.deployment.ClusterClientJobClientAdapter
getJobGraph(Pipeline, Configuration) - 类中的静态方法org.apache.flink.client.deployment.executors.PipelineExecutorUtils: Creates the JobGraph corresponding to the provided Pipeline.
getJobGraph(Pipeline, Configuration, int) - 类中的静态方法org.apache.flink.client.FlinkPipelineTranslationUtil: Transmogrifies the given Pipeline to a JobGraph.
getJobGraphUnderUserClassLoader(ClassLoader, Pipeline, Configuration, int) - 类中的静态方法org.apache.flink.client.FlinkPipelineTranslationUtil: Transmogrifies the given Pipeline under the userClassloader to a JobGraph.
getJobID() - 类中的方法org.apache.flink.client.deployment.application.EmbeddedJobClient
getJobID() - 类中的方法org.apache.flink.client.deployment.application.WebSubmissionJobClient
getJobID() - 类中的方法org.apache.flink.client.deployment.ClusterClientJobClientAdapter
getJobJarAndDependencies() - 类中的方法org.apache.flink.client.program.PackagedProgram: Returns all provided libraries needed to run the program.
getJobStatus() - 类中的方法org.apache.flink.client.deployment.application.EmbeddedJobClient
getJobStatus() - 类中的方法org.apache.flink.client.deployment.application.WebSubmissionJobClient
getJobStatus() - 类中的方法org.apache.flink.client.deployment.ClusterClientJobClientAdapter
getJobStatus(JobID) - 接口中的方法org.apache.flink.client.program.ClusterClient: Requests the JobStatus of the job with the given JobID.
getJobStatus(JobID) - 类中的方法org.apache.flink.client.program.MiniClusterClient
getJobStatus(JobID) - 类中的方法org.apache.flink.client.program.rest.RestClusterClient
getMainClassName() - 类中的方法org.apache.flink.client.program.PackagedProgram
getMasterMemoryMB() - 类中的方法org.apache.flink.client.deployment.ClusterSpecification
getName() - 类中的方法org.apache.flink.client.deployment.application.executors.EmbeddedExecutorFactory
getName() - 类中的方法org.apache.flink.client.deployment.application.executors.WebSubmissionExecutorFactory
getName() - 类中的方法org.apache.flink.client.deployment.executors.LocalExecutorFactory
getName() - 类中的方法org.apache.flink.client.deployment.executors.RemoteExecutorFactory
getPackagedProgram() - 类中的方法org.apache.flink.client.deployment.application.ClassPathPackagedProgramRetriever
getPackagedProgram() - 接口中的方法org.apache.flink.client.program.PackagedProgramRetriever: Retrieve the PackagedProgram.
getParallelism() - 类中的方法org.apache.flink.client.cli.ExecutionConfigAccessor
getParallelism() - 类中的方法org.apache.flink.client.cli.ProgramOptions
getPipeline() - 类中的方法org.apache.flink.client.program.OptimizerPlanEnvironment
getPipeline() - 类中的方法org.apache.flink.client.program.StreamPlanEnvironment
getPipelineFromProgram(PackagedProgram, Configuration, int, boolean) - 枚举中的静态方法org.apache.flink.client.program.PackagedProgramUtils
getProgramArgs() - 类中的方法org.apache.flink.client.cli.ProgramOptions
getProgramArguments() - 类中的方法org.apache.flink.client.deployment.application.ApplicationConfiguration
getPythonJar() - 枚举中的静态方法org.apache.flink.client.program.PackagedProgramUtils
getRestClientConfiguration() - 类中的方法org.apache.flink.client.program.rest.RestClusterClientConfiguration
getRetryDelay() - 类中的方法org.apache.flink.client.program.rest.RestClusterClientConfiguration
getRetryMaxAttempts() - 类中的方法org.apache.flink.client.program.rest.RestClusterClientConfiguration
getRunCommandOptions() - 类中的静态方法org.apache.flink.client.cli.CliFrontendParser
getSavepointPath() - 类中的方法org.apache.flink.client.cli.SavepointOptions
getSavepointRestoreSettings() - 类中的方法org.apache.flink.client.cli.ExecutionConfigAccessor
getSavepointRestoreSettings() - 类中的方法org.apache.flink.client.cli.ProgramOptions
getSavepointSettings() - 类中的方法org.apache.flink.client.program.PackagedProgram
getSavepointTargetDirectory() - 类中的方法org.apache.flink.client.cli.CancelOptions
getSlotsPerTaskManager() - 类中的方法org.apache.flink.client.deployment.ClusterSpecification
getTaskManagerMemoryMB() - 类中的方法org.apache.flink.client.deployment.ClusterSpecification
getUserCodeClassLoader() - 类中的方法org.apache.flink.client.program.PackagedProgram: Gets the ClassLoader that must be used to load user code classes.
getWebInterfaceURL() - 接口中的方法org.apache.flink.client.program.ClusterClient: Returns an URL (as a string) to the cluster web interface.
getWebInterfaceURL() - 类中的方法org.apache.flink.client.program.MiniClusterClient
getWebInterfaceURL() - 类中的方法org.apache.flink.client.program.rest.RestClusterClient

H

handleCliArgsException(CliArgsException, Logger) - 类中的静态方法org.apache.flink.client.cli.AbstractCustomCommandLine
handleError(Throwable, Logger) - 类中的静态方法org.apache.flink.client.cli.AbstractCustomCommandLine

I

ID - 类中的静态变量org.apache.flink.client.cli.DefaultCLI
info(String[]) - 类中的方法org.apache.flink.client.cli.CliFrontend: Executes the info action.
initialize(Dispatcher, ScheduledExecutor) - 类中的方法org.apache.flink.client.deployment.application.ApplicationDispatcherBootstrap
invokeInteractiveModeForExecution() - 类中的方法org.apache.flink.client.program.PackagedProgram: This method assumes that the context environment is prepared, or the execution will be a local execution by default.
isActive(CommandLine) - 接口中的方法org.apache.flink.client.cli.CustomCommandLine: Signals whether the custom command-line wants to execute or not.
isActive(CommandLine) - 类中的方法org.apache.flink.client.cli.DefaultCLI
isActive(CommandLine) - 类中的方法org.apache.flink.client.cli.GenericCLI
isCompatibleWith(Configuration) - 类中的方法org.apache.flink.client.deployment.application.executors.EmbeddedExecutorFactory
isCompatibleWith(Configuration) - 类中的方法org.apache.flink.client.deployment.application.executors.WebSubmissionExecutorFactory
isCompatibleWith(Configuration) - 接口中的方法org.apache.flink.client.deployment.ClusterClientFactory: Returns true if the current ClusterClientFactory is compatible with the provided configuration, false otherwise.
isCompatibleWith(Configuration) - 类中的方法org.apache.flink.client.deployment.executors.LocalExecutorFactory
isCompatibleWith(Configuration) - 类中的方法org.apache.flink.client.deployment.executors.RemoteExecutorFactory
isCompatibleWith(Configuration) - 类中的方法org.apache.flink.client.deployment.StandaloneClientFactory
isDispose() - 类中的方法org.apache.flink.client.cli.SavepointOptions
isPrintHelp() - 类中的方法org.apache.flink.client.cli.CommandLineOptions
isPython(String) - 枚举中的静态方法org.apache.flink.client.program.PackagedProgramUtils
isPythonEntryPoint(CommandLine) - 枚举中的静态方法org.apache.flink.client.cli.ProgramOptionsUtils
isShutdownOnAttachedExit() - 类中的方法org.apache.flink.client.cli.ExecutionConfigAccessor
isShutdownOnAttachedExit() - 类中的方法org.apache.flink.client.cli.ProgramOptions
isWithSavepoint() - 类中的方法org.apache.flink.client.cli.CancelOptions

K

killCluster(T) - 接口中的方法org.apache.flink.client.deployment.ClusterDescriptor: Terminates the cluster with the given cluster id.
killCluster(StandaloneClusterId) - 类中的方法org.apache.flink.client.deployment.StandaloneClusterDescriptor

L

list(String[]) - 类中的方法org.apache.flink.client.cli.CliFrontend: Executes the list action.
listJobs() - 接口中的方法org.apache.flink.client.program.ClusterClient: Lists the currently running and finished jobs on the cluster.
listJobs() - 类中的方法org.apache.flink.client.program.MiniClusterClient
listJobs() - 类中的方法org.apache.flink.client.program.rest.RestClusterClient
ListOptions - org.apache.flink.client.cli中的类: Command line options for the LIST command.
ListOptions(CommandLine) - 类的构造器org.apache.flink.client.cli.ListOptions
loadCustomCommandLines(Configuration, String) - 类中的静态方法org.apache.flink.client.cli.CliFrontend
LocalExecutor - org.apache.flink.client.deployment.executors中的类: An PipelineExecutor for executing a Pipeline locally.
LocalExecutorFactory - org.apache.flink.client.deployment.executors中的类: An PipelineExecutorFactory for local executors.
LocalExecutorFactory() - 类的构造器org.apache.flink.client.deployment.executors.LocalExecutorFactory

M

main(String[]) - 类中的静态方法org.apache.flink.client.cli.CliFrontend: Submits the job based on the arguments.
MANIFEST_ATTRIBUTE_ASSEMBLER_CLASS - 类中的静态变量org.apache.flink.client.program.PackagedProgram: Property name of the entry in JAR manifest file that describes the Flink specific entry point.
MANIFEST_ATTRIBUTE_MAIN_CLASS - 类中的静态变量org.apache.flink.client.program.PackagedProgram: Property name of the entry in JAR manifest file that describes the class with the main method.
mergeOptions(Options, Options) - 类中的静态方法org.apache.flink.client.cli.CliFrontendParser: Merges the given Options into a new Options object.
MiniClusterClient - org.apache.flink.client.program中的类: Client to interact with a MiniCluster.
MiniClusterClient(Configuration, MiniCluster) - 类的构造器org.apache.flink.client.program.MiniClusterClient
MiniClusterClient.MiniClusterId - org.apache.flink.client.program中的枚举: The type of the Cluster ID for the local MiniCluster.

N

NAME - 类中的静态变量org.apache.flink.client.deployment.application.executors.EmbeddedExecutor
NAME - 类中的静态变量org.apache.flink.client.deployment.executors.LocalExecutor
NAME - 类中的静态变量org.apache.flink.client.deployment.executors.RemoteExecutor
newBuilder(String[]) - 类中的静态方法org.apache.flink.client.deployment.application.ClassPathPackagedProgramRetriever
newBuilder() - 类中的静态方法org.apache.flink.client.program.PackagedProgram

O

OptimizerPlanEnvironment - org.apache.flink.client.program中的类: An ExecutionEnvironment that never executes a job but only extracts the Pipeline.
OptimizerPlanEnvironment(Configuration, ClassLoader, int) - 类的构造器org.apache.flink.client.program.OptimizerPlanEnvironment
org.apache.flink.client - 程序包 org.apache.flink.client
org.apache.flink.client.cli - 程序包 org.apache.flink.client.cli
org.apache.flink.client.deployment - 程序包 org.apache.flink.client.deployment
org.apache.flink.client.deployment.application - 程序包 org.apache.flink.client.deployment.application
org.apache.flink.client.deployment.application.cli - 程序包 org.apache.flink.client.deployment.application.cli
org.apache.flink.client.deployment.application.executors - 程序包 org.apache.flink.client.deployment.application.executors
org.apache.flink.client.deployment.executors - 程序包 org.apache.flink.client.deployment.executors
org.apache.flink.client.program - 程序包 org.apache.flink.client.program
org.apache.flink.client.program.rest - 程序包 org.apache.flink.client.program.rest
org.apache.flink.client.program.rest.retry - 程序包 org.apache.flink.client.program.rest.retry

P

PackagedProgram - org.apache.flink.client.program中的类: This class encapsulates represents a program, packaged in a jar file.
PackagedProgram.Builder - org.apache.flink.client.program中的类: A Builder For PackagedProgram.
PackagedProgramRetriever - org.apache.flink.client.program中的接口: Interface which allows to retrieve the PackagedProgram.
PackagedProgramUtils - org.apache.flink.client.program中的枚举: Utility class for PackagedProgram related operations.
PARALLELISM_OPTION - 类中的静态变量org.apache.flink.client.cli.CliFrontendParser
parse(Options, String[], boolean) - 类中的静态方法org.apache.flink.client.cli.CliFrontendParser
parseCommandLineOptions(String[], boolean) - 接口中的方法org.apache.flink.client.cli.CustomCommandLine
parseParameters(String[]) - 类中的方法org.apache.flink.client.cli.CliFrontend: Parses the command line arguments and starts the requested action.
PerJobMiniClusterFactory - org.apache.flink.client.program中的类: Starts a MiniCluster for every submitted job.
PipelineExecutorUtils - org.apache.flink.client.deployment.executors中的类: Utility class with method related to job execution.
PipelineExecutorUtils() - 类的构造器org.apache.flink.client.deployment.executors.PipelineExecutorUtils
PlanTranslator - org.apache.flink.client中的类: FlinkPipelineTranslator for DataSet API Plans.
PlanTranslator() - 类的构造器org.apache.flink.client.PlanTranslator
printHelp(Collection<CustomCommandLine>) - 类中的静态方法org.apache.flink.client.cli.CliFrontendParser: Prints the help for the client.
printHelpForCancel(Collection<CustomCommandLine>) - 类中的静态方法org.apache.flink.client.cli.CliFrontendParser
printHelpForInfo() - 类中的静态方法org.apache.flink.client.cli.CliFrontendParser
printHelpForList(Collection<CustomCommandLine>) - 类中的静态方法org.apache.flink.client.cli.CliFrontendParser
printHelpForRun(Collection<CustomCommandLine>) - 类中的静态方法org.apache.flink.client.cli.CliFrontendParser
printHelpForSavepoint(Collection<CustomCommandLine>) - 类中的静态方法org.apache.flink.client.cli.CliFrontendParser
printHelpForStop(Collection<CustomCommandLine>) - 类中的静态方法org.apache.flink.client.cli.CliFrontendParser
printUsage() - 类中的方法org.apache.flink.client.cli.AbstractCustomCommandLine
ProgramAbortException - org.apache.flink.client.program中的错误: A special exception used to abort programs when the caller is only interested in the program plan, rather than in the full execution.
ProgramAbortException() - 错误的构造器org.apache.flink.client.program.ProgramAbortException
ProgramInvocationException - org.apache.flink.client.program中的异常错误: Exception used to indicate that there is an error during the invocation of a Flink program.
ProgramInvocationException(String) - 异常错误的构造器org.apache.flink.client.program.ProgramInvocationException: Creates a ProgramInvocationException with the given message.
ProgramInvocationException(String, JobID) - 异常错误的构造器org.apache.flink.client.program.ProgramInvocationException: Creates a ProgramInvocationException with the given message which contains job id.
ProgramInvocationException(Throwable) - 异常错误的构造器org.apache.flink.client.program.ProgramInvocationException: Creates a ProgramInvocationException for the given exception.
ProgramInvocationException(String, Throwable) - 异常错误的构造器org.apache.flink.client.program.ProgramInvocationException: Creates a ProgramInvocationException for the given exception with an additional message.
ProgramInvocationException(String, JobID, Throwable) - 异常错误的构造器org.apache.flink.client.program.ProgramInvocationException: Creates a ProgramInvocationException for the given exception with an additional message which contains job id.
ProgramMissingJobException - org.apache.flink.client.program中的异常错误: Exception used to indicate that no job was executed during the invocation of a Flink program.
ProgramMissingJobException(String) - 异常错误的构造器org.apache.flink.client.program.ProgramMissingJobException
ProgramOptions - org.apache.flink.client.cli中的类: Base class for command line options that refer to a JAR file program.
ProgramOptions(CommandLine) - 类的构造器org.apache.flink.client.cli.ProgramOptions
ProgramOptionsUtils - org.apache.flink.client.cli中的枚举: Utility class for ProgramOptions.
ProgramParametrizationException - org.apache.flink.client.program中的异常错误: Exception used to indicate that there is an error in the parametrization of a Flink program.
ProgramParametrizationException(String) - 异常错误的构造器org.apache.flink.client.program.ProgramParametrizationException: Creates a ProgramParametrizationException with the given message.
PY_OPTION - 类中的静态变量org.apache.flink.client.cli.CliFrontendParser
PYARCHIVE_OPTION - 类中的静态变量org.apache.flink.client.cli.CliFrontendParser
PYEXEC_OPTION - 类中的静态变量org.apache.flink.client.cli.CliFrontendParser
PYFILES_OPTION - 类中的静态变量org.apache.flink.client.cli.CliFrontendParser
PYMODULE_OPTION - 类中的静态变量org.apache.flink.client.cli.CliFrontendParser
PYREQUIREMENTS_OPTION - 类中的静态变量org.apache.flink.client.cli.CliFrontendParser

R

RemoteExecutor - org.apache.flink.client.deployment.executors中的类: The PipelineExecutor to be used when executing a job on an already running cluster.
RemoteExecutor() - 类的构造器org.apache.flink.client.deployment.executors.RemoteExecutor
RemoteExecutorFactory - org.apache.flink.client.deployment.executors中的类: An PipelineExecutorFactory for remote executors.
RemoteExecutorFactory() - 类的构造器org.apache.flink.client.deployment.executors.RemoteExecutorFactory
requestJobResult(JobID) - 接口中的方法org.apache.flink.client.program.ClusterClient: Request the JobResult for the given JobID.
requestJobResult(JobID) - 类中的方法org.apache.flink.client.program.MiniClusterClient
requestJobResult(JobID) - 类中的方法org.apache.flink.client.program.rest.RestClusterClient: Requests the JobResult for the given JobID.
resolveURI(String) - 枚举中的静态方法org.apache.flink.client.program.PackagedProgramUtils
RestClusterClient<T> - org.apache.flink.client.program.rest中的类: A ClusterClient implementation that communicates via HTTP REST requests.
RestClusterClient(Configuration, T) - 类的构造器org.apache.flink.client.program.rest.RestClusterClient
RestClusterClient(Configuration, T, ClientHighAvailabilityServices) - 类的构造器org.apache.flink.client.program.rest.RestClusterClient
RestClusterClientConfiguration - org.apache.flink.client.program.rest中的类: A configuration object for RestClusterClients.
retrieve(T) - 接口中的方法org.apache.flink.client.deployment.ClusterDescriptor: Retrieves an existing Flink Cluster.
retrieve(StandaloneClusterId) - 类中的方法org.apache.flink.client.deployment.StandaloneClusterDescriptor
run(Configuration, ApplicationConfiguration) - 接口中的方法org.apache.flink.client.cli.ApplicationDeployer: Submits a user program for execution and runs the main user method on the cluster.
run(String[]) - 类中的方法org.apache.flink.client.cli.CliFrontend: Executions the run action.
run(DispatcherGateway, PackagedProgram, Configuration) - 接口中的方法org.apache.flink.client.deployment.application.ApplicationRunner: Runs the application using the provided dispatcherGateway.
run(Configuration, ApplicationConfiguration) - 类中的方法org.apache.flink.client.deployment.application.cli.ApplicationClusterDeployer
run(DispatcherGateway, PackagedProgram, Configuration) - 类中的方法org.apache.flink.client.deployment.application.DetachedApplicationRunner
runApplication(String[]) - 类中的方法org.apache.flink.client.cli.CliFrontend

S

savepoint(String[]) - 类中的方法org.apache.flink.client.cli.CliFrontend: Executes the SAVEPOINT action.
SAVEPOINT_ALLOW_NON_RESTORED_OPTION - 类中的静态变量org.apache.flink.client.cli.CliFrontendParser
SAVEPOINT_PATH_OPTION - 类中的静态变量org.apache.flink.client.cli.CliFrontendParser
SavepointOptions - org.apache.flink.client.cli中的类: Command line options for the SAVEPOINT command.
SavepointOptions(CommandLine) - 类的构造器org.apache.flink.client.cli.SavepointOptions
sendCoordinationRequest(OperatorID, CoordinationRequest) - 类中的方法org.apache.flink.client.deployment.application.EmbeddedJobClient
sendCoordinationRequest(OperatorID, CoordinationRequest) - 类中的方法org.apache.flink.client.deployment.ClusterClientJobClientAdapter
sendCoordinationRequest(JobID, OperatorID, CoordinationRequest) - 接口中的方法org.apache.flink.client.program.ClusterClient: Sends out a request to a specified coordinator and return the response.
sendCoordinationRequest(JobID, OperatorID, CoordinationRequest) - 类中的方法org.apache.flink.client.program.MiniClusterClient
sendCoordinationRequest(JobID, OperatorID, CoordinationRequest) - 类中的方法org.apache.flink.client.program.rest.RestClusterClient
sendRequest(M, U, R) - 类中的方法org.apache.flink.client.program.rest.RestClusterClient
setArguments(String...) - 类中的方法org.apache.flink.client.program.PackagedProgram.Builder
setAsContext(PipelineExecutorServiceLoader, Configuration, ClassLoader, boolean, boolean) - 类中的静态方法org.apache.flink.client.program.ContextEnvironment
setAsContext() - 类中的方法org.apache.flink.client.program.OptimizerPlanEnvironment
setAsContext(PipelineExecutorServiceLoader, Configuration, ClassLoader, boolean, boolean) - 类中的静态方法org.apache.flink.client.program.StreamContextEnvironment
setAsContext() - 类中的方法org.apache.flink.client.program.StreamPlanEnvironment
setConfiguration(Configuration) - 类中的方法org.apache.flink.client.program.PackagedProgram.Builder
setEntryPointClassName(String) - 类中的方法org.apache.flink.client.program.PackagedProgram.Builder
setJarFile(File) - 类中的方法org.apache.flink.client.deployment.application.ClassPathPackagedProgramRetriever.Builder
setJarFile(File) - 类中的方法org.apache.flink.client.program.PackagedProgram.Builder
setJarsOnClassPath(Supplier<Iterable<File>>) - 类中的方法org.apache.flink.client.deployment.application.ClassPathPackagedProgramRetriever.Builder
setJobClassName(String) - 类中的方法org.apache.flink.client.deployment.application.ClassPathPackagedProgramRetriever.Builder
setMasterMemoryMB(int) - 类中的方法org.apache.flink.client.deployment.ClusterSpecification.ClusterSpecificationBuilder
setSavepointRestoreSettings(SavepointRestoreSettings) - 类中的方法org.apache.flink.client.program.PackagedProgram.Builder
setSlotsPerTaskManager(int) - 类中的方法org.apache.flink.client.deployment.ClusterSpecification.ClusterSpecificationBuilder
setTaskManagerMemoryMB(int) - 类中的方法org.apache.flink.client.deployment.ClusterSpecification.ClusterSpecificationBuilder
setUserClassPaths(List<URL>) - 类中的方法org.apache.flink.client.program.PackagedProgram.Builder
setUserLibDirectory(File) - 类中的方法org.apache.flink.client.deployment.application.ClassPathPackagedProgramRetriever.Builder
showAll() - 类中的方法org.apache.flink.client.cli.ListOptions
showRunning() - 类中的方法org.apache.flink.client.cli.ListOptions
showScheduled() - 类中的方法org.apache.flink.client.cli.ListOptions
SHUTDOWN_IF_ATTACHED_OPTION - 类中的静态变量org.apache.flink.client.cli.CliFrontendParser
shutDownCluster() - 接口中的方法org.apache.flink.client.program.ClusterClient: Shut down the cluster that this client communicate with.
shutDownCluster() - 类中的方法org.apache.flink.client.program.MiniClusterClient
shutDownCluster() - 类中的方法org.apache.flink.client.program.rest.RestClusterClient
sleepTime(long) - 类中的方法org.apache.flink.client.program.rest.retry.ExponentialWaitStrategy
sleepTime(long) - 接口中的方法org.apache.flink.client.program.rest.retry.WaitStrategy: Returns the time to wait until the next attempt.
StandaloneClientFactory - org.apache.flink.client.deployment中的类: A ClusterClientFactory for a standalone cluster, i.e.
StandaloneClientFactory() - 类的构造器org.apache.flink.client.deployment.StandaloneClientFactory
StandaloneClusterDescriptor - org.apache.flink.client.deployment中的类: A deployment descriptor for an existing cluster.
StandaloneClusterDescriptor(Configuration) - 类的构造器org.apache.flink.client.deployment.StandaloneClusterDescriptor
StandaloneClusterId - org.apache.flink.client.deployment中的类: Identifier for standalone clusters.
stop(String[]) - 类中的方法org.apache.flink.client.cli.CliFrontend: Executes the STOP action.
stop() - 类中的方法org.apache.flink.client.deployment.application.ApplicationDispatcherBootstrap
STOP_AND_DRAIN - 类中的静态变量org.apache.flink.client.cli.CliFrontendParser
STOP_WITH_SAVEPOINT_PATH - 类中的静态变量org.apache.flink.client.cli.CliFrontendParser
stopWithSavepoint(boolean, String) - 类中的方法org.apache.flink.client.deployment.application.EmbeddedJobClient
stopWithSavepoint(boolean, String) - 类中的方法org.apache.flink.client.deployment.application.WebSubmissionJobClient
stopWithSavepoint(boolean, String) - 类中的方法org.apache.flink.client.deployment.ClusterClientJobClientAdapter
stopWithSavepoint(JobID, boolean, String) - 接口中的方法org.apache.flink.client.program.ClusterClient: Stops a program on Flink cluster whose job-manager is configured in this client's configuration.
stopWithSavepoint(JobID, boolean, String) - 类中的方法org.apache.flink.client.program.MiniClusterClient
stopWithSavepoint(JobID, boolean, String) - 类中的方法org.apache.flink.client.program.rest.RestClusterClient
StreamContextEnvironment - org.apache.flink.client.program中的类: Special StreamExecutionEnvironment that will be used in cases where the CLI client or testing utilities create a StreamExecutionEnvironment that should be used when StreamExecutionEnvironment.getExecutionEnvironment() is called.
StreamContextEnvironment(PipelineExecutorServiceLoader, Configuration, ClassLoader, boolean, boolean) - 类的构造器org.apache.flink.client.program.StreamContextEnvironment
StreamGraphTranslator - org.apache.flink.client中的类: FlinkPipelineTranslator for DataStream API StreamGraphs.
StreamGraphTranslator() - 类的构造器org.apache.flink.client.StreamGraphTranslator
StreamPlanEnvironment - org.apache.flink.client.program中的类: A special StreamExecutionEnvironment that is used in the web frontend when generating a user-inspectable graph of a streaming job.
StreamPlanEnvironment(Configuration, ClassLoader, int) - 类的构造器org.apache.flink.client.program.StreamPlanEnvironment
submitJob(ClusterClient<?>, JobGraph) - 枚举中的静态方法org.apache.flink.client.ClientUtils
submitJob(JobGraph) - 接口中的方法org.apache.flink.client.program.ClusterClient: Submit the given JobGraph to the cluster.
submitJob(JobGraph) - 类中的方法org.apache.flink.client.program.MiniClusterClient
submitJob(JobGraph) - 类中的方法org.apache.flink.client.program.PerJobMiniClusterFactory: Starts a MiniCluster and submits a job.
submitJob(JobGraph) - 类中的方法org.apache.flink.client.program.rest.RestClusterClient
submitJobAndWaitForResult(ClusterClient<?>, JobGraph, ClassLoader) - 枚举中的静态方法org.apache.flink.client.ClientUtils

T

toString() - 类中的方法org.apache.flink.client.deployment.ClusterSpecification
toString() - 类中的方法org.apache.flink.client.program.ContextEnvironment
translateToJobGraph(Pipeline, Configuration, int) - 接口中的方法org.apache.flink.client.FlinkPipelineTranslator: Creates a JobGraph from the given Pipeline and attaches the given jar files and classpaths to the JobGraph.
translateToJobGraph(Pipeline, Configuration, int) - 类中的方法org.apache.flink.client.PlanTranslator
translateToJobGraph(Pipeline, Configuration, int) - 类中的方法org.apache.flink.client.StreamGraphTranslator
translateToJSONExecutionPlan(Pipeline) - 类中的静态方法org.apache.flink.client.FlinkPipelineTranslationUtil: Extracts the execution plan (as JSON) from the given Pipeline.
translateToJSONExecutionPlan(Pipeline) - 接口中的方法org.apache.flink.client.FlinkPipelineTranslator: Extracts the execution plan (as JSON) from the given Pipeline.
translateToJSONExecutionPlan(Pipeline) - 类中的方法org.apache.flink.client.PlanTranslator
translateToJSONExecutionPlan(Pipeline) - 类中的方法org.apache.flink.client.StreamGraphTranslator
triggerSavepoint(String) - 类中的方法org.apache.flink.client.deployment.application.EmbeddedJobClient
triggerSavepoint(String) - 类中的方法org.apache.flink.client.deployment.application.WebSubmissionJobClient
triggerSavepoint(String) - 类中的方法org.apache.flink.client.deployment.ClusterClientJobClientAdapter
triggerSavepoint(JobID, String) - 接口中的方法org.apache.flink.client.program.ClusterClient: Triggers a savepoint for the job identified by the job id.
triggerSavepoint(JobID, String) - 类中的方法org.apache.flink.client.program.MiniClusterClient
triggerSavepoint(JobID, String) - 类中的方法org.apache.flink.client.program.rest.RestClusterClient

U

unsetAsContext() - 类中的静态方法org.apache.flink.client.program.ContextEnvironment
unsetAsContext() - 类中的方法org.apache.flink.client.program.OptimizerPlanEnvironment
unsetAsContext() - 类中的静态方法org.apache.flink.client.program.StreamContextEnvironment
unsetAsContext() - 类中的方法org.apache.flink.client.program.StreamPlanEnvironment

V

validate() - 类中的方法org.apache.flink.client.cli.ProgramOptions
validateAndGetActiveCommandLine(CommandLine) - 类中的方法org.apache.flink.client.cli.CliFrontend: Gets the custom command-line for the arguments.
valueOf(String) - 枚举中的静态方法org.apache.flink.client.cli.ProgramOptionsUtils: 返回带有指定名称的该类型的枚举常量。
valueOf(String) - 枚举中的静态方法org.apache.flink.client.ClientUtils: 返回带有指定名称的该类型的枚举常量。
valueOf(String) - 枚举中的静态方法org.apache.flink.client.program.MiniClusterClient.MiniClusterId: 返回带有指定名称的该类型的枚举常量。
valueOf(String) - 枚举中的静态方法org.apache.flink.client.program.PackagedProgramUtils: 返回带有指定名称的该类型的枚举常量。
values() - 枚举中的静态方法org.apache.flink.client.cli.ProgramOptionsUtils: 按照声明该枚举类型的常量的顺序, 返回包含这些常量的数组。
values() - 枚举中的静态方法org.apache.flink.client.ClientUtils: 按照声明该枚举类型的常量的顺序, 返回包含这些常量的数组。
values() - 枚举中的静态方法org.apache.flink.client.program.MiniClusterClient.MiniClusterId: 按照声明该枚举类型的常量的顺序, 返回包含这些常量的数组。
values() - 枚举中的静态方法org.apache.flink.client.program.PackagedProgramUtils: 按照声明该枚举类型的常量的顺序, 返回包含这些常量的数组。

W

WaitStrategy - org.apache.flink.client.program.rest.retry中的接口: Operations that are polling for a result to arrive require a waiting time between consecutive polls.
WebSubmissionExecutorFactory - org.apache.flink.client.deployment.application.executors中的类: A PipelineExecutorFactory for an EmbeddedExecutor that returns a WebSubmissionJobClient.
WebSubmissionExecutorFactory(Collection<JobID>, DispatcherGateway) - 类的构造器org.apache.flink.client.deployment.application.executors.WebSubmissionExecutorFactory: Creates an WebSubmissionExecutorFactory.
WebSubmissionExecutorServiceLoader - org.apache.flink.client.deployment.application.executors中的类: A PipelineExecutorServiceLoader that always returns an WebSubmissionExecutorFactory.
WebSubmissionExecutorServiceLoader(Collection<JobID>, DispatcherGateway) - 类的构造器org.apache.flink.client.deployment.application.executors.WebSubmissionExecutorServiceLoader: Creates an WebSubmissionExecutorServiceLoader.
WebSubmissionJobClient - org.apache.flink.client.deployment.application中的类: A JobClient that only allows asking for the job id of the job it is attached to.
WebSubmissionJobClient(JobID) - 类的构造器org.apache.flink.client.deployment.application.WebSubmissionJobClient

Y

YARN_DETACHED_OPTION - 类中的静态变量org.apache.flink.client.cli.CliFrontendParser: 已过时。
use non-prefixed variant CliFrontendParser.DETACHED_OPTION for both YARN and non-YARN deployments

Z

ZERO_JOB_ID - 类中的静态变量org.apache.flink.client.deployment.application.ApplicationDispatcherBootstrap
zookeeperNamespaceOption - 类中的变量org.apache.flink.client.cli.AbstractCustomCommandLine

A B C D E F G H I K L M N O P R S T U V W Y Z