Package org.apache.flink.test.util
Class MiniClusterWithClientResource
- java.lang.Object
-
- MiniClusterResource
-
- org.apache.flink.test.util.MiniClusterWithClientResource
-
public class MiniClusterWithClientResource extends MiniClusterResource
Starts a Flink mini cluster as a resource and registers the StreamExecutionEnvironment.
-
-
Constructor Summary
Constructors Constructor Description MiniClusterWithClientResource(MiniClusterResourceConfiguration miniClusterResourceConfiguration)
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description void
after()
void
before()
ClusterClient<?>
getClusterClient()
RestClusterClient<?>
getRestClusterClient()
Returns aRestClusterClient
that can be used to communicate with this mini cluster.TestStreamEnvironment
getTestStreamEnvironment()
-
-
-
Method Detail
-
getClusterClient
public ClusterClient<?> getClusterClient()
-
getRestClusterClient
public RestClusterClient<?> getRestClusterClient() throws Exception
Returns aRestClusterClient
that can be used to communicate with this mini cluster. Only use this if the client returned viagetClusterClient()
does not fulfill your needs.- Throws:
Exception
-
getTestStreamEnvironment
public TestStreamEnvironment getTestStreamEnvironment()
-
after
public void after()
-
-