public final class PerJobMiniClusterFactory extends Object
MiniCluster
for every submitted job.
This class guarantees to tear down the MiniCluster in case of normal or exceptional job completion.Modifier and Type | Method and Description |
---|---|
static PerJobMiniClusterFactory |
create() |
static PerJobMiniClusterFactory |
createWithFactory(Configuration configuration,
java.util.function.Function<? super MiniClusterConfiguration,? extends MiniCluster> miniClusterFactory) |
CompletableFuture<? extends JobClient> |
submitJob(JobGraph jobGraph)
Starts a
MiniCluster and submits a job. |
public static PerJobMiniClusterFactory create()
public static PerJobMiniClusterFactory createWithFactory(Configuration configuration, java.util.function.Function<? super MiniClusterConfiguration,? extends MiniCluster> miniClusterFactory)
public CompletableFuture<? extends JobClient> submitJob(JobGraph jobGraph) throws Exception
MiniCluster
and submits a job.Exception
Copyright © 2014–2020 The Apache Software Foundation. All rights reserved.