org.apache.flink.tests.util.flink

Class LocalStandaloneFlinkResource

java.lang.Object

org.apache.flink.tests.util.flink.LocalStandaloneFlinkResource

All Implemented Interfaces:

FlinkResource, ExternalResource, org.junit.rules.TestRule

public class LocalStandaloneFlinkResource
extends Object
implements FlinkResource

Flink resource that start local standalone clusters.

Constructor Summary

Constructors

Constructor and Description
LocalStandaloneFlinkResource()

Method Summary

Modifier and Type	Method and Description
void	addConfiguration(Configuration config) Adds the given configuration to the existing configuration of this resource.
void	afterTestFailure()
void	afterTestSuccess()
void	before()
ClusterController	startCluster(int numTaskManagers) Starts a cluster.

Methods inherited from class java.lang.Object

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

Methods inherited from interface org.apache.flink.tests.util.flink.FlinkResource

get

Methods inherited from interface org.apache.flink.util.ExternalResource

apply

Constructor Detail

LocalStandaloneFlinkResource

public LocalStandaloneFlinkResource()

Method Detail

before

public void before()
            throws Exception

Specified by:

before in interface ExternalResource

Throws:

Exception

afterTestSuccess

public void afterTestSuccess()

Specified by:

afterTestSuccess in interface ExternalResource

afterTestFailure

public void afterTestFailure()

Specified by:

afterTestFailure in interface ExternalResource

addConfiguration

public void addConfiguration(Configuration config)
                      throws IOException

Description copied from interface: FlinkResource

Adds the given configuration to the existing configuration of this resource. Entries in the existing configuration will be overwritten.

Specified by:

addConfiguration in interface FlinkResource

Parameters:

config - config to add

Throws:

IOException

startCluster

public ClusterController startCluster(int numTaskManagers)
                               throws IOException

Description copied from interface: FlinkResource

Starts a cluster.

The exact constellation of the cluster is undefined.

In the case of per-job clusters this method may not start any Flink processes, deferring this to ClusterController.submitJob(JobSubmission).

Specified by:

startCluster in interface FlinkResource

Parameters:

numTaskManagers - number of task managers

Returns:

controller for interacting with the cluster

Throws:

IOException