public class BenchmarkJob
extends java.lang.Object
| Modifier and Type | Class and Description |
|---|---|
static class |
BenchmarkJob.TimestampsAndWatermarks |
| Constructor and Description |
|---|
BenchmarkJob(java.util.List<Window> assigner,
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 BenchmarkJob(java.util.List<Window> assigner, 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)