public class FlinkBenchmarkJob
extends java.lang.Object
| Constructor and Description |
|---|
FlinkBenchmarkJob(java.util.List<Window> assigners,
org.apache.flink.streaming.api.environment.StreamExecutionEnvironment env,
long runtime,
int throughput,
java.util.List<org.apache.flink.api.java.tuple.Tuple2<java.lang.Long,java.lang.Long>> gaps) |
public FlinkBenchmarkJob(java.util.List<Window> assigners, org.apache.flink.streaming.api.environment.StreamExecutionEnvironment env, long runtime, int throughput, java.util.List<org.apache.flink.api.java.tuple.Tuple2<java.lang.Long,java.lang.Long>> gaps)