org.apache.flink.statefun.e2e.smoke

Class SmokeRunner

java.lang.Object

org.apache.flink.statefun.e2e.smoke.SmokeRunner

public final class SmokeRunner
extends java.lang.Object

Constructor Summary

Constructors

Constructor and Description
SmokeRunner()

Method Summary

Modifier and Type	Method and Description
static void	awaitVerificationSuccess(java.util.function.Supplier<VerificationResult> results, int numberOfFunctionInstances)
static void	run(SmokeRunnerParameters parameters, StatefulFunctionsAppContainers.Builder builder)

Methods inherited from class java.lang.Object

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

Constructor Detail

SmokeRunner

public SmokeRunner()

Method Detail

run

public static void run(SmokeRunnerParameters parameters,
                       StatefulFunctionsAppContainers.Builder builder)
                throws java.lang.Throwable

Throws:

java.lang.Throwable

awaitVerificationSuccess

public static void awaitVerificationSuccess(java.util.function.Supplier<VerificationResult> results,
                                            int numberOfFunctionInstances)