public final class FlinkDistribution
extends org.junit.rules.ExternalResource
Constructor and Description |
---|
FlinkDistribution() |
Modifier and Type | Method and Description |
---|---|
protected void |
after() |
void |
appendConfiguration(Configuration config) |
protected void |
before() |
void |
copyOptJarsToLib(String jarNamePrefix) |
java.util.stream.Stream<String> |
searchAllLogs(Pattern pattern,
java.util.function.Function<Matcher,String> matchProcessor) |
void |
startFlinkCluster() |
void |
stopFlinkCluster() |
protected void before() throws IOException
before
in class org.junit.rules.ExternalResource
IOException
protected void after()
after
in class org.junit.rules.ExternalResource
public void startFlinkCluster() throws IOException
IOException
public void stopFlinkCluster() 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.