in src/main/java/org/apache/flink/benchmark/functions/LongSource.java [33:45]
public void run(SourceContext<Long> ctx) throws Exception {
long counter = 0;
while (running) {
synchronized (ctx.getCheckpointLock()) {
ctx.collect(counter);
counter++;
if (counter >= maxValue) {
cancel();
}
}
}
}