Uses of Class
org.apache.flink.runtime.minicluster.MiniCluster

Packages that use MiniCluster

Package	Description
org.apache.flink.client.deployment.executors
org.apache.flink.client.program
org.apache.flink.runtime.minicluster
org.apache.flink.streaming.util
org.apache.flink.test.util

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

Method parameters in org.apache.flink.client.deployment.executors with type arguments of type MiniCluster

Modifier and Type	Method and Description
static LocalExecutor	LocalExecutor.createWithFactory(Configuration configuration, Function<MiniClusterConfiguration,MiniCluster> miniClusterFactory)

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

Method parameters in org.apache.flink.client.program with type arguments of type MiniCluster

Modifier and Type	Method and Description
static PerJobMiniClusterFactory	PerJobMiniClusterFactory.createWithFactory(Configuration configuration, Function<? super MiniClusterConfiguration,? extends MiniCluster> miniClusterFactory)

Constructors in org.apache.flink.client.program with parameters of type MiniCluster

Constructor and Description
MiniClusterClient(Configuration configuration, MiniCluster miniCluster)

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

Constructors in org.apache.flink.runtime.minicluster with parameters of type MiniCluster

Constructor and Description
MiniClusterJobClient(JobID jobID, MiniCluster miniCluster, ClassLoader classLoader, MiniClusterJobClient.JobFinalizationBehavior finalizationBehaviour) Creates a MiniClusterJobClient for the given JobID and MiniCluster.

Uses of MiniCluster in org.apache.flink.streaming.util

Methods in org.apache.flink.streaming.util with parameters of type MiniCluster

Modifier and Type	Method and Description
static void	TestStreamEnvironment.setAsContext(MiniCluster miniCluster, int parallelism) Sets the streaming context environment to a TestStreamEnvironment that runs its programs on the given cluster with the given default parallelism.
static void	TestStreamEnvironment.setAsContext(MiniCluster miniCluster, int parallelism, Collection<Path> jarFiles, Collection<URL> classpaths) Sets the streaming context environment to a TestStreamEnvironment that runs its programs on the given cluster with the given default parallelism and the specified jar files and class paths.

Constructors in org.apache.flink.streaming.util with parameters of type MiniCluster

Constructor and Description
TestStreamEnvironment(MiniCluster miniCluster, Configuration config, int parallelism, Collection<Path> jarFiles, Collection<URL> classPaths)
TestStreamEnvironment(MiniCluster miniCluster, int parallelism)

Uses of MiniCluster in org.apache.flink.test.util

Methods in org.apache.flink.test.util with parameters of type MiniCluster

Modifier and Type	Method and Description
static void	TestEnvironment.setAsContext(MiniCluster miniCluster, int parallelism) Sets the current ExecutionEnvironment to be a TestEnvironment.
static void	TestEnvironment.setAsContext(MiniCluster miniCluster, int parallelism, Collection<Path> jarFiles, Collection<URL> classPaths) Sets the current ExecutionEnvironment to be a TestEnvironment.

Constructors in org.apache.flink.test.util with parameters of type MiniCluster

Constructor and Description
MiniClusterPipelineExecutorServiceLoader(MiniCluster miniCluster)
TestEnvironment(MiniCluster executor, int parallelism, boolean isObjectReuseEnabled)
TestEnvironment(MiniCluster miniCluster, int parallelism, boolean isObjectReuseEnabled, Collection<Path> jarFiles, Collection<URL> classPaths)