Package 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	Description
static PerJobMiniClusterFactory	create()
static PerJobMiniClusterFactory	createWithFactory(Configuration configuration, Function<? super MiniClusterConfiguration,? extends MiniCluster> miniClusterFactory)
CompletableFuture<JobClient>	submitJob(ExecutionPlan executionPlan, 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(ExecutionPlan executionPlan,
                                              ClassLoader userCodeClassloader)
                                       throws Exception

Starts a MiniCluster and submits a job.

Throws:

Exception