stream.scotty.flinkBenchmark

Class BenchmarkRunner

java.lang.Object

flinkBenchmark.stream.scotty.BenchmarkRunner

public class BenchmarkRunner
extends java.lang.Object

Created by philipp on 5/28/17.

Field Summary

Fields

Modifier and Type	Field and Description
private static java.lang.String	configPath

Constructor Summary

Constructors

Constructor and Description
BenchmarkRunner()

Method Summary

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)

Methods inherited from class java.lang.Object

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

Field Detail

configPath

private static java.lang.String configPath

Constructor Detail

BenchmarkRunner

public BenchmarkRunner()

Method Detail

main

public static void main(java.lang.String[] args)
                 throws java.lang.Exception

Throws:

java.lang.Exception

getAssigners

private static java.util.List<Window> getAssigners(java.util.List<java.lang.String> config)

getAssigner

private static java.util.Collection<Window> getAssigner(java.lang.String windowConfig)

generateSessionGaps

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)

loadConfig

private static BenchmarkConfig loadConfig()
                                   throws java.lang.Exception

Throws:

java.lang.Exception