Uses of Interface
org.apache.flink.core.execution.JobClient

Packages that use JobClient

Package	Description
org.apache.flink.api.java
org.apache.flink.client
org.apache.flink.client.deployment
org.apache.flink.client.deployment.application
org.apache.flink.client.deployment.application.executors
org.apache.flink.client.deployment.executors
org.apache.flink.client.program
org.apache.flink.connector.testframe.container
org.apache.flink.connector.testframe.environment
org.apache.flink.connector.testframe.testsuites
org.apache.flink.core.execution
org.apache.flink.runtime.minicluster
org.apache.flink.streaming.api.environment
org.apache.flink.streaming.api.operators.collect
org.apache.flink.table.api
org.apache.flink.table.api.internal
org.apache.flink.table.delegation
org.apache.flink.table.executor.python
org.apache.flink.table.planner.delegation

Uses of JobClient in org.apache.flink.api.java

Methods in org.apache.flink.api.java that return JobClient

Modifier and Type	Method and Description
JobClient	ExecutionEnvironment.executeAsync() Deprecated. Triggers the program execution asynchronously.
JobClient	ExecutionEnvironment.executeAsync(String jobName) Deprecated. Triggers the program execution asynchronously.

Uses of JobClient in org.apache.flink.client

Methods in org.apache.flink.client with parameters of type JobClient

Modifier and Type	Method and Description
static ScheduledExecutorService	ClientUtils.reportHeartbeatPeriodically(JobClient jobClient, long interval, long timeout) The client reports the heartbeat to the dispatcher for aliveness.

Uses of JobClient in org.apache.flink.client.deployment

Classes in org.apache.flink.client.deployment that implement JobClient

Modifier and Type	Class and Description
class	ClusterClientJobClientAdapter<ClusterID> An implementation of the JobClient interface that uses a ClusterClient underneath..

Uses of JobClient in org.apache.flink.client.deployment.application

Classes in org.apache.flink.client.deployment.application that implement JobClient

Modifier and Type	Class and Description
class	EmbeddedJobClient A JobClient with the ability to also submit jobs which uses directly the DispatcherGateway.
class	WebSubmissionJobClient A JobClient that only allows asking for the job id of the job it is attached to.

Uses of JobClient in org.apache.flink.client.deployment.application.executors

Methods in org.apache.flink.client.deployment.application.executors that return JobClient

Modifier and Type	Method and Description
JobClient	EmbeddedJobClientCreator.getJobClient(JobID jobId, ClassLoader userCodeClassloader) Creates a JobClient that is adequate for the context in which the job is executed.

Methods in org.apache.flink.client.deployment.application.executors that return types with arguments of type JobClient

Modifier and Type	Method and Description
CompletableFuture<JobClient>	EmbeddedExecutor.execute(Pipeline pipeline, Configuration configuration, ClassLoader userCodeClassloader)

Uses of JobClient in org.apache.flink.client.deployment.executors

Methods in org.apache.flink.client.deployment.executors that return types with arguments of type JobClient

Modifier and Type	Method and Description
CompletableFuture<JobClient>	AbstractJobClusterExecutor.execute(Pipeline pipeline, Configuration configuration, ClassLoader userCodeClassloader) Deprecated.
CompletableFuture<JobClient>	LocalExecutor.execute(Pipeline pipeline, Configuration configuration, ClassLoader userCodeClassloader)
CompletableFuture<JobClient>	AbstractSessionClusterExecutor.execute(Pipeline pipeline, Configuration configuration, ClassLoader userCodeClassloader)

Uses of JobClient in org.apache.flink.client.program

Methods in org.apache.flink.client.program that return JobClient

Modifier and Type	Method and Description
JobClient	StreamPlanEnvironment.executeAsync(StreamGraph streamGraph)
JobClient	StreamContextEnvironment.executeAsync(StreamGraph streamGraph)
JobClient	ContextEnvironment.executeAsync(String jobName)
JobClient	OptimizerPlanEnvironment.executeAsync(String jobName)

Methods in org.apache.flink.client.program that return types with arguments of type JobClient

Modifier and Type	Method and Description
CompletableFuture<JobClient>	PerJobMiniClusterFactory.submitJob(JobGraph jobGraph, ClassLoader userCodeClassloader) Starts a MiniCluster and submits a job.

Uses of JobClient in org.apache.flink.connector.testframe.container

Methods in org.apache.flink.connector.testframe.container with parameters of type JobClient

Modifier and Type	Method and Description
void	FlinkContainerTestEnvironment.isolateNetwork(JobClient jobClient, Runnable afterFailAction)
void	FlinkContainerTestEnvironment.triggerJobManagerFailover(JobClient jobClient, Runnable afterFailAction)
void	FlinkContainerTestEnvironment.triggerTaskManagerFailover(JobClient jobClient, Runnable afterFailAction)

Uses of JobClient in org.apache.flink.connector.testframe.environment

Methods in org.apache.flink.connector.testframe.environment with parameters of type JobClient

Modifier and Type	Method and Description
void	MiniClusterTestEnvironment.isolateNetwork(JobClient jobClient, Runnable afterFailAction)
void	ClusterControllable.isolateNetwork(JobClient jobClient, Runnable afterFailAction) Disconnect network between Flink cluster and external system.
void	MiniClusterTestEnvironment.triggerJobManagerFailover(JobClient jobClient, Runnable afterFailAction)
void	ClusterControllable.triggerJobManagerFailover(JobClient jobClient, Runnable afterFailAction) Triggers a JobManager failover.
void	MiniClusterTestEnvironment.triggerTaskManagerFailover(JobClient jobClient, Runnable afterFailAction)
void	ClusterControllable.triggerTaskManagerFailover(JobClient jobClient, Runnable afterFailAction) Triggers TaskManager failover.

Uses of JobClient in org.apache.flink.connector.testframe.testsuites

Methods in org.apache.flink.connector.testframe.testsuites that return JobClient

Modifier and Type	Method and Description
protected JobClient	SourceTestSuiteBase.submitJob(StreamExecutionEnvironment env, String jobName)

Methods in org.apache.flink.connector.testframe.testsuites with parameters of type JobClient

Modifier and Type	Method and Description
protected CollectResultIterator<T>	SourceTestSuiteBase.CollectIteratorBuilder.build(JobClient jobClient)

Uses of JobClient in org.apache.flink.core.execution

Methods in org.apache.flink.core.execution that return types with arguments of type JobClient

Modifier and Type	Method and Description
CompletableFuture<JobClient>	PipelineExecutor.execute(Pipeline pipeline, Configuration configuration, ClassLoader userCodeClassloader) Executes a Pipeline based on the provided configuration and returns a JobClient which allows to interact with the job being executed, e.g. cancel it or take a savepoint.

Methods in org.apache.flink.core.execution with parameters of type JobClient

Modifier and Type	Method and Description
void	JobListener.onJobSubmitted(JobClient jobClient, Throwable throwable) Callback on job submission.

Uses of JobClient in org.apache.flink.runtime.minicluster

Classes in org.apache.flink.runtime.minicluster that implement JobClient

Modifier and Type	Class and Description
class	MiniClusterJobClient A JobClient for a MiniCluster.

Uses of JobClient in org.apache.flink.streaming.api.environment

Methods in org.apache.flink.streaming.api.environment that return JobClient

Modifier and Type	Method and Description
JobClient	StreamExecutionEnvironment.executeAsync() Triggers the program asynchronously.
JobClient	StreamExecutionEnvironment.executeAsync(StreamGraph streamGraph) Triggers the program execution asynchronously.
JobClient	StreamExecutionEnvironment.executeAsync(String jobName) Triggers the program execution asynchronously.

Uses of JobClient in org.apache.flink.streaming.api.operators.collect

Fields in org.apache.flink.streaming.api.operators.collect declared as JobClient

Modifier and Type	Field and Description
JobClient	ClientAndIterator.client

Methods in org.apache.flink.streaming.api.operators.collect with parameters of type JobClient

Modifier and Type	Method and Description
void	CollectResultFetcher.setJobClient(JobClient jobClient)
void	CollectResultIterator.setJobClient(JobClient jobClient)

Constructors in org.apache.flink.streaming.api.operators.collect with parameters of type JobClient

Constructor and Description
ClientAndIterator(JobClient client, CloseableIterator<E> iterator)

Uses of JobClient in org.apache.flink.table.api

Methods in org.apache.flink.table.api that return types with arguments of type JobClient

Modifier and Type	Method and Description
Optional<JobClient>	TableResult.getJobClient() For DML and DQL statement, return the JobClient which associates the submitted Flink job.

Uses of JobClient in org.apache.flink.table.api.internal

Methods in org.apache.flink.table.api.internal that return types with arguments of type JobClient

Modifier and Type	Method and Description
Optional<JobClient>	TableResultImpl.getJobClient()

Methods in org.apache.flink.table.api.internal with parameters of type JobClient

Modifier and Type	Method and Description
TableResultImpl.Builder	TableResultImpl.Builder.jobClient(JobClient jobClient) Specifies job client which associates the submitted Flink job.
StaticResultProvider	StaticResultProvider.setJobClient(JobClient jobClient)
ResultProvider	ResultProvider.setJobClient(JobClient jobClient) Set the job client associated with the select job to retrieve the result.

Uses of JobClient in org.apache.flink.table.delegation

Methods in org.apache.flink.table.delegation that return JobClient

Modifier and Type	Method and Description
JobClient	Executor.executeAsync(Pipeline pipeline) Executes the given pipeline asynchronously.

Uses of JobClient in org.apache.flink.table.executor.python

Methods in org.apache.flink.table.executor.python that return JobClient

Modifier and Type	Method and Description
JobClient	ChainingOptimizingExecutor.executeAsync(Pipeline pipeline)

Uses of JobClient in org.apache.flink.table.planner.delegation

Methods in org.apache.flink.table.planner.delegation that return JobClient

Modifier and Type	Method and Description
JobClient	DefaultExecutor.executeAsync(Pipeline pipeline)