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.

Method Summary

Modifier and Type	Method and Description
void	afterTestFailure()
void	afterTestSuccess()
void	before()
java.util.stream.Stream<String>	searchAllLogs(Pattern pattern, java.util.function.Function<Matcher,String> matchProcessor) Searches the logs of all processes for the given pattern, and applies the given processor for every line for which Matcher.matches() returned true.
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, get

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

apply

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

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

Specified by:

startCluster in interface FlinkResource

Parameters:

numTaskManagers - number of task managers

Returns:

controller for interacting with the cluster

Throws:

IOException

searchAllLogs

public java.util.stream.Stream<String> searchAllLogs(Pattern pattern,
                                                     java.util.function.Function<Matcher,String> matchProcessor)
                                              throws IOException

Description copied from interface: FlinkResource

Searches the logs of all processes for the given pattern, and applies the given processor for every line for which Matcher.matches() returned true.

Specified by:

searchAllLogs in interface FlinkResource

Parameters:

pattern - pattern to search for

matchProcessor - match processor

Returns:

stream of matched strings

Throws:

IOException