public class BenchmarkRunner
extends java.lang.Object
| Modifier and Type | Field and Description |
|---|---|
private static java.lang.String |
configPath |
| Constructor and Description |
|---|
BenchmarkRunner() |
| Modifier and Type | Method and Description |
|---|---|
static java.util.List<org.apache.flink.api.java.tuple.Tuple2<java.lang.Long,java.lang.Long>> |
generateSessionGaps(int gapCount,
int maxTs,
int minGapTime,
int maxGapTime) |
private static java.util.Collection<Window> |
getAssigner(java.lang.String windowConfig) |
private static java.util.List<Window> |
getAssigners(java.util.List<java.lang.String> config) |
private static BenchmarkConfig |
loadConfig() |
static void |
main(java.lang.String[] args) |
public static void main(java.lang.String[] args)
throws java.lang.Exception
java.lang.Exceptionprivate static java.util.List<Window> getAssigners(java.util.List<java.lang.String> config)
private static java.util.Collection<Window> getAssigner(java.lang.String windowConfig)
public static java.util.List<org.apache.flink.api.java.tuple.Tuple2<java.lang.Long,java.lang.Long>> generateSessionGaps(int gapCount,
int maxTs,
int minGapTime,
int maxGapTime)
private static BenchmarkConfig loadConfig() throws java.lang.Exception
java.lang.Exception