org.apache.flink.tests.util.flink

Interface FlinkResource

All Superinterfaces:

ExternalResource, org.junit.rules.TestRule

All Known Implementing Classes:

LocalStandaloneFlinkResource

public interface FlinkResource
extends ExternalResource

Generic interface for interacting with Flink.

Method Summary

Modifier and Type	Method and Description
void	addConfiguration(Configuration config) Adds the given configuration to the existing configuration of this resource.
static FlinkResource	get() Returns the configured FlinkResource implementation, or a LocalStandaloneFlinkResource if none is configured.
ClusterController	startCluster(int numTaskManagers) Starts a cluster.

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

afterTestFailure, afterTestSuccess, apply, before

Method Detail

addConfiguration

void addConfiguration(Configuration config)
               throws IOException

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

Parameters:

config - config to add

Throws:

IOException

startCluster

ClusterController startCluster(int numTaskManagers)
                        throws IOException

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).

Parameters:

numTaskManagers - number of task managers

Returns:

controller for interacting with the cluster

Throws:

IOException

get

static FlinkResource get()

Returns the configured FlinkResource implementation, or a LocalStandaloneFlinkResource if none is configured.

Returns:

configured FlinkResource, or LocalStandaloneFlinkResource is none is configured