org.apache.flink.client.program

Class PerJobMiniClusterFactory

java.lang.Object

org.apache.flink.client.program.PerJobMiniClusterFactory

public final class PerJobMiniClusterFactory
extends Object

Starts a MiniCluster for every submitted job. This class guarantees to tear down the MiniCluster in case of normal or exceptional job completion.

Method Summary

Modifier and Type	Method and Description
static PerJobMiniClusterFactory	create()
static PerJobMiniClusterFactory	createWithFactory(Configuration configuration, Function<? super MiniClusterConfiguration,? extends MiniCluster> miniClusterFactory)
CompletableFuture<JobClient>	submitJob(JobGraph jobGraph, ClassLoader userCodeClassloader) Starts a MiniCluster and submits a job.

Methods inherited from class java.lang.Object

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

Method Detail

create

public static PerJobMiniClusterFactory create()

createWithFactory

public static PerJobMiniClusterFactory createWithFactory(Configuration configuration,
                                                         Function<? super MiniClusterConfiguration,? extends MiniCluster> miniClusterFactory)

submitJob

public CompletableFuture<JobClient> submitJob(JobGraph jobGraph,
                                              ClassLoader userCodeClassloader)
                                       throws Exception

Starts a MiniCluster and submits a job.

Throws:

Exception