stream.scotty.flinkBenchmark

Class FlinkBenchmarkJob

java.lang.Object

flinkBenchmark.stream.scotty.FlinkBenchmarkJob

public class FlinkBenchmarkJob
extends java.lang.Object

Constructor Summary

Constructors

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)

Method Summary

Methods inherited from class java.lang.Object

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

Constructor Detail

FlinkBenchmarkJob

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)