stream.scotty.flinkBenchmark

Class BenchmarkJob

java.lang.Object

flinkBenchmark.stream.scotty.BenchmarkJob

public class BenchmarkJob
extends java.lang.Object

Created by philipp on 5/28/17.

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static class	BenchmarkJob.TimestampsAndWatermarks

Constructor Summary

Constructors

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)

Method Summary

Methods inherited from class java.lang.Object

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

Constructor Detail

BenchmarkJob

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)