org.apache.flink.tests.util.flink

Class FlinkDistribution

java.lang.Object

org.apache.flink.tests.util.flink.FlinkDistribution

public final class FlinkDistribution
extends Object

A wrapper around a Flink distribution.

Constructor Summary

Constructors

Constructor and Description
FlinkDistribution(Path distributionDir)

Method Summary

Modifier and Type	Method and Description
void	appendConfiguration(Configuration config)
void	callJobManagerScript(String... args)
void	copyLogsTo(Path targetDirectory)
void	performJarAddition(org.apache.flink.tests.util.flink.JarAddition addition)
void	performJarOperation(org.apache.flink.tests.util.flink.JarOperation operation)
<T> java.util.stream.Stream<T>	searchAllLogs(Pattern pattern, java.util.function.Function<Matcher,T> matchProcessor)
void	setRootLogLevel(org.slf4j.event.Level logLevel)
void	setTaskExecutorHosts(Collection<String> taskExecutorHosts)
void	startFlinkCluster()
void	startJobManager()
void	startSqlGateway()
void	startTaskManager()
void	stopFlinkCluster()
void	stopSqlGateway()
JobID	submitJob(JobSubmission jobSubmission, java.time.Duration timeout)
void	submitSQLJob(SQLJobSubmission job, java.time.Duration timeout)

Methods inherited from class java.lang.Object

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

Constructor Detail

FlinkDistribution

public FlinkDistribution(Path distributionDir)

Method Detail

startJobManager

public void startJobManager()
                     throws IOException

Throws:

IOException

callJobManagerScript

public void callJobManagerScript(String... args)
                          throws IOException

Throws:

IOException

startTaskManager

public void startTaskManager()
                      throws IOException

Throws:

IOException

startSqlGateway

public void startSqlGateway()
                     throws IOException

Throws:

IOException

stopSqlGateway

public void stopSqlGateway()
                    throws IOException

Throws:

IOException

setRootLogLevel

public void setRootLogLevel(org.slf4j.event.Level logLevel)
                     throws IOException

Throws:

IOException

startFlinkCluster

public void startFlinkCluster()
                       throws IOException

Throws:

IOException

stopFlinkCluster

public void stopFlinkCluster()
                      throws IOException

Throws:

IOException

submitJob

public JobID submitJob(JobSubmission jobSubmission,
                       java.time.Duration timeout)
                throws IOException

Throws:

IOException

submitSQLJob

public void submitSQLJob(SQLJobSubmission job,
                         java.time.Duration timeout)
                  throws Exception

Throws:

Exception

performJarAddition

public void performJarAddition(org.apache.flink.tests.util.flink.JarAddition addition)
                        throws IOException

Throws:

IOException

performJarOperation

public void performJarOperation(org.apache.flink.tests.util.flink.JarOperation operation)
                         throws IOException

Throws:

IOException

appendConfiguration

public void appendConfiguration(Configuration config)
                         throws IOException

Throws:

IOException

setTaskExecutorHosts

public void setTaskExecutorHosts(Collection<String> taskExecutorHosts)
                          throws IOException

Throws:

IOException

searchAllLogs

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

Throws:

IOException

copyLogsTo

public void copyLogsTo(Path targetDirectory)
                throws IOException

Throws:

IOException