org.apache.flink.statefun.e2e.smoke.driver

Class CommandGenerator

java.lang.Object

org.apache.flink.statefun.e2e.smoke.driver.CommandGenerator

All Implemented Interfaces:

java.util.function.Supplier<SourceCommand>

public final class CommandGenerator
extends java.lang.Object
implements java.util.function.Supplier<SourceCommand>

Generates random commands to be interpreted by functions of type Constants.FN_TYPE.

see {src/main/protobuf/commands.proto}

Constructor Summary

Constructors

Constructor and Description
CommandGenerator(org.apache.commons.math3.random.RandomGenerator random, SmokeRunnerParameters parameters)

Method Summary

Modifier and Type	Method and Description
SourceCommand	get()

Methods inherited from class java.lang.Object

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

Constructor Detail

CommandGenerator

public CommandGenerator(org.apache.commons.math3.random.RandomGenerator random,
                        SmokeRunnerParameters parameters)

Method Detail

get

public SourceCommand get()

Specified by:

get in interface java.util.function.Supplier<SourceCommand>