stream.scotty.flinkBenchmark

Class LoadGeneratorSource

java.lang.Object

flinkBenchmark.stream.scotty.LoadGeneratorSource

All Implemented Interfaces:

java.io.Serializable, org.apache.flink.api.common.functions.Function, org.apache.flink.streaming.api.functions.source.SourceFunction<org.apache.flink.api.java.tuple.Tuple4<java.lang.String,java.lang.Integer,java.lang.Long,java.lang.Long>>

public class LoadGeneratorSource
extends java.lang.Object
implements org.apache.flink.streaming.api.functions.source.SourceFunction<org.apache.flink.api.java.tuple.Tuple4<java.lang.String,java.lang.Integer,java.lang.Long,java.lang.Long>>

See Also:

Serialized Form

Nested Class Summary

Nested classes/interfaces inherited from interface org.apache.flink.streaming.api.functions.source.SourceFunction

org.apache.flink.streaming.api.functions.source.SourceFunction.SourceContext<T>

Field Summary

Fields

Modifier and Type	Field and Description
private int	backpressureCounter
private int	currentGapIndex
private java.util.List<org.apache.flink.api.java.tuple.Tuple2<java.lang.Long,java.lang.Long>>	gaps
private static org.slf4j.Logger	LOG
private static int	maxBackpressure
private long	nextGapEnd
private long	nextGapStart
private java.util.Random	random
private boolean	running
private long	runtime
private int	throughput
private long	timeOffset

Constructor Summary

Constructors

Constructor and Description
LoadGeneratorSource(long runtime, int throughput, java.util.List<org.apache.flink.api.java.tuple.Tuple2<java.lang.Long,java.lang.Long>> gaps)

Method Summary

Modifier and Type	Method and Description
void	cancel()
private void	emitValue(org.apache.flink.api.java.tuple.Tuple4<java.lang.String,java.lang.Integer,java.lang.Long,java.lang.Long> tuple3, org.apache.flink.streaming.api.functions.source.SourceFunction.SourceContext<org.apache.flink.api.java.tuple.Tuple4<java.lang.String,java.lang.Integer,java.lang.Long,java.lang.Long>> ctx)
private org.apache.flink.api.java.tuple.Tuple4<java.lang.String,java.lang.Integer,java.lang.Long,java.lang.Long>	readNextTuple()
void	run(org.apache.flink.streaming.api.functions.source.SourceFunction.SourceContext<org.apache.flink.api.java.tuple.Tuple4<java.lang.String,java.lang.Integer,java.lang.Long,java.lang.Long>> ctx)

Methods inherited from class java.lang.Object

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

Field Detail

maxBackpressure

private static int maxBackpressure

runtime

private final long runtime

LOG

private static final org.slf4j.Logger LOG

throughput

private final int throughput

running

private boolean running

gaps

private final java.util.List<org.apache.flink.api.java.tuple.Tuple2<java.lang.Long,java.lang.Long>> gaps

currentGapIndex

private int currentGapIndex

nextGapStart

private long nextGapStart

nextGapEnd

private long nextGapEnd

timeOffset

private long timeOffset

random

private java.util.Random random

backpressureCounter

private int backpressureCounter

Constructor Detail

LoadGeneratorSource

public LoadGeneratorSource(long runtime,
                           int throughput,
                           java.util.List<org.apache.flink.api.java.tuple.Tuple2<java.lang.Long,java.lang.Long>> gaps)

Method Detail

run

public void run(org.apache.flink.streaming.api.functions.source.SourceFunction.SourceContext<org.apache.flink.api.java.tuple.Tuple4<java.lang.String,java.lang.Integer,java.lang.Long,java.lang.Long>> ctx)
         throws java.lang.Exception

Specified by:

run in interface org.apache.flink.streaming.api.functions.source.SourceFunction<org.apache.flink.api.java.tuple.Tuple4<java.lang.String,java.lang.Integer,java.lang.Long,java.lang.Long>>

Throws:

java.lang.Exception

emitValue

private void emitValue(org.apache.flink.api.java.tuple.Tuple4<java.lang.String,java.lang.Integer,java.lang.Long,java.lang.Long> tuple3,
                       org.apache.flink.streaming.api.functions.source.SourceFunction.SourceContext<org.apache.flink.api.java.tuple.Tuple4<java.lang.String,java.lang.Integer,java.lang.Long,java.lang.Long>> ctx)

readNextTuple

private org.apache.flink.api.java.tuple.Tuple4<java.lang.String,java.lang.Integer,java.lang.Long,java.lang.Long> readNextTuple()
                                                                                                                        throws java.lang.Exception

Throws:

java.lang.Exception

cancel

public void cancel()

Specified by:

cancel in interface org.apache.flink.streaming.api.functions.source.SourceFunction<org.apache.flink.api.java.tuple.Tuple4<java.lang.String,java.lang.Integer,java.lang.Long,java.lang.Long>>