org.apache.flink.test.util

Class MiniClusterWithClientResource

java.lang.Object

org.junit.rules.ExternalResource

org.apache.flink.runtime.testutils.MiniClusterResource

org.apache.flink.test.util.MiniClusterWithClientResource

All Implemented Interfaces:

org.junit.rules.TestRule

Direct Known Subclasses:

MiniClusterResource

public class MiniClusterWithClientResource
extends org.apache.flink.runtime.testutils.MiniClusterResource

Starts a Flink mini cluster as a resource and registers the respective ExecutionEnvironment and StreamExecutionEnvironment.

Field Summary

Fields inherited from class org.apache.flink.runtime.testutils.MiniClusterResource

log

Constructor Summary

Constructors

Constructor and Description
MiniClusterWithClientResource(org.apache.flink.runtime.testutils.MiniClusterResourceConfiguration miniClusterResourceConfiguration)

Method Summary

Modifier and Type	Method and Description
void	after()
void	before()
ClusterClient<?>	getClusterClient()
TestEnvironment	getTestEnvironment()

Methods inherited from class org.apache.flink.runtime.testutils.MiniClusterResource

getClientConfiguration, getMiniCluster, getNumberSlots, getRestAddres

Methods inherited from class org.junit.rules.ExternalResource

apply

Methods inherited from class java.lang.Object

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

Constructor Detail

MiniClusterWithClientResource

public MiniClusterWithClientResource(org.apache.flink.runtime.testutils.MiniClusterResourceConfiguration miniClusterResourceConfiguration)

Method Detail

getClusterClient

public ClusterClient<?> getClusterClient()

getTestEnvironment

public TestEnvironment getTestEnvironment()

before

public void before()
            throws Exception

Overrides:

before in class org.apache.flink.runtime.testutils.MiniClusterResource

Throws:

Exception

after

public void after()

Overrides:

after in class org.apache.flink.runtime.testutils.MiniClusterResource