public final class FlinkDistribution extends Object implements ExternalResource
Constructor and Description |
---|
FlinkDistribution() |
Modifier and Type | Method and Description |
---|---|
void |
afterTestFailure() |
void |
afterTestSuccess() |
void |
appendConfiguration(Configuration config) |
void |
before() |
void |
copyOptJarsToLib(String jarNamePrefix) |
java.util.stream.Stream<String> |
searchAllLogs(Pattern pattern,
java.util.function.Function<Matcher,String> matchProcessor) |
void |
startFlinkCluster() |
void |
startJobManager() |
void |
startTaskManager() |
void |
stopFlinkCluster() |
JobID |
submitJob(JobSubmission jobSubmission) |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
apply
public void before() throws IOException
before
in interface ExternalResource
IOException
public void afterTestSuccess()
afterTestSuccess
in interface ExternalResource
public void afterTestFailure()
afterTestFailure
in interface ExternalResource
public void startJobManager() throws IOException
IOException
public void startTaskManager() throws IOException
IOException
public void startFlinkCluster() throws IOException
IOException
public void stopFlinkCluster() throws IOException
IOException
public JobID submitJob(JobSubmission jobSubmission) throws IOException
IOException
public void copyOptJarsToLib(String jarNamePrefix) throws FileNotFoundException, IOException
FileNotFoundException
IOException
public void appendConfiguration(Configuration config) throws IOException
IOException
public java.util.stream.Stream<String> searchAllLogs(Pattern pattern, java.util.function.Function<Matcher,String> matchProcessor) throws IOException
IOException
Copyright © 2014–2020 The Apache Software Foundation. All rights reserved.